| Index: third_party/WebKit/Source/platform/scheduler/base/work_queue.h
|
| diff --git a/third_party/WebKit/Source/platform/scheduler/base/work_queue.h b/third_party/WebKit/Source/platform/scheduler/base/work_queue.h
|
| index f6e520608d1855941e0b794b58fff0060ded7122..ae1f21415f09e46bf87a70509ee2a4a31ccb1320 100644
|
| --- a/third_party/WebKit/Source/platform/scheduler/base/work_queue.h
|
| +++ b/third_party/WebKit/Source/platform/scheduler/base/work_queue.h
|
| @@ -30,7 +30,9 @@
|
| // throttling mechanisms.
|
| class BLINK_PLATFORM_EXPORT WorkQueue {
|
| public:
|
| - WorkQueue(TaskQueueImpl* task_queue, const char* name);
|
| + WorkQueue(TaskQueueImpl* task_queue,
|
| + const char* name,
|
| + TaskQueueImpl::Task::ComparatorFn queue_comparator);
|
| ~WorkQueue();
|
|
|
| // Associates this work queue with the given work queue sets. This must be
|
| @@ -54,7 +56,7 @@
|
| // method ignores any fences.
|
| const TaskQueueImpl::Task* GetFrontTask() const;
|
|
|
| - // Returns the last task in this queue or null if the queue is empty. This
|
| + // Returns the first task in this queue or null if the queue is empty. This
|
| // method ignores any fences.
|
| const TaskQueueImpl::Task* GetBackTask() const;
|
|
|
| @@ -62,10 +64,20 @@
|
| // informs the WorkQueueSets if the head changed.
|
| void Push(TaskQueueImpl::Task task);
|
|
|
| + // Removes a cancelled task from the |work_queue_|. Note |key| isn't required
|
| + // to be the original task posted, it can be a fake key constructed by
|
| + // TaskQueueImpl::Task::CreateFakeTaskFromHandle.
|
| + bool CancelTask(const TaskQueueImpl::Task& key);
|
| +
|
| + // Returns true if |work_queue_| contains a task matching |key|. Note |key|
|
| + // isn't required to be the original task posted, it can be a fake key
|
| + // constructed by TaskQueueImpl::Task::CreateFakeTaskFromHandle.
|
| + bool IsTaskPending(const TaskQueueImpl::Task& key) const;
|
| +
|
| // Swap the |work_queue_| with |incoming_queue| and if a fence hasn't been
|
| // reached it informs the WorkQueueSets if the head changed. Assumes
|
| // |task_queue_->any_thread_lock_| is locked.
|
| - void SwapLocked(std::queue<TaskQueueImpl::Task>& incoming_queue);
|
| + void SwapLocked(TaskQueueImpl::ComparatorQueue& incoming_queue);
|
|
|
| size_t Size() const { return work_queue_.size(); }
|
|
|
| @@ -108,7 +120,7 @@
|
| bool BlockedByFence() const;
|
|
|
| private:
|
| - std::queue<TaskQueueImpl::Task> work_queue_;
|
| + TaskQueueImpl::ComparatorQueue work_queue_;
|
| WorkQueueSets* work_queue_sets_; // NOT OWNED.
|
| TaskQueueImpl* task_queue_; // NOT OWNED.
|
| size_t work_queue_set_index_;
|
|
|