| OLD | NEW |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #ifndef THIRD_PARTY_WEBKIT_SOURCE_PLATFORM_SCHEDULER_BASE_TASK_QUEUE_IMPL_H_ | 5 #ifndef THIRD_PARTY_WEBKIT_SOURCE_PLATFORM_SCHEDULER_BASE_TASK_QUEUE_IMPL_H_ |
| 6 #define THIRD_PARTY_WEBKIT_SOURCE_PLATFORM_SCHEDULER_BASE_TASK_QUEUE_IMPL_H_ | 6 #define THIRD_PARTY_WEBKIT_SOURCE_PLATFORM_SCHEDULER_BASE_TASK_QUEUE_IMPL_H_ |
| 7 | 7 |
| 8 #include <stddef.h> | 8 #include <stddef.h> |
| 9 | 9 |
| 10 #include <memory> | 10 #include <memory> |
| (...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 62 TaskQueueImpl(TaskQueueManager* task_queue_manager, | 62 TaskQueueImpl(TaskQueueManager* task_queue_manager, |
| 63 TimeDomain* time_domain, | 63 TimeDomain* time_domain, |
| 64 const Spec& spec, | 64 const Spec& spec, |
| 65 const char* disabled_by_default_tracing_category, | 65 const char* disabled_by_default_tracing_category, |
| 66 const char* disabled_by_default_verbose_tracing_category); | 66 const char* disabled_by_default_verbose_tracing_category); |
| 67 | 67 |
| 68 class BLINK_PLATFORM_EXPORT Task : public base::PendingTask { | 68 class BLINK_PLATFORM_EXPORT Task : public base::PendingTask { |
| 69 public: | 69 public: |
| 70 Task(); | 70 Task(); |
| 71 Task(const tracked_objects::Location& posted_from, | 71 Task(const tracked_objects::Location& posted_from, |
| 72 base::Closure task, | 72 base::OnceClosure task, |
| 73 base::TimeTicks desired_run_time, | 73 base::TimeTicks desired_run_time, |
| 74 EnqueueOrder sequence_number, | 74 EnqueueOrder sequence_number, |
| 75 bool nestable); | 75 bool nestable); |
| 76 | 76 |
| 77 Task(const tracked_objects::Location& posted_from, | 77 Task(const tracked_objects::Location& posted_from, |
| 78 base::Closure task, | 78 base::OnceClosure task, |
| 79 base::TimeTicks desired_run_time, | 79 base::TimeTicks desired_run_time, |
| 80 EnqueueOrder sequence_number, | 80 EnqueueOrder sequence_number, |
| 81 bool nestable, | 81 bool nestable, |
| 82 EnqueueOrder enqueue_order); | 82 EnqueueOrder enqueue_order); |
| 83 | 83 |
| 84 EnqueueOrder enqueue_order() const { | 84 EnqueueOrder enqueue_order() const { |
| 85 #ifndef NDEBUG | 85 #ifndef NDEBUG |
| 86 DCHECK(enqueue_order_set_); | 86 DCHECK(enqueue_order_set_); |
| 87 #endif | 87 #endif |
| 88 return enqueue_order_; | 88 return enqueue_order_; |
| (...skipping 35 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 124 return (sequence_num - other.sequence_num) < 0; | 124 return (sequence_num - other.sequence_num) < 0; |
| 125 } | 125 } |
| 126 return time < other.time; | 126 return time < other.time; |
| 127 } | 127 } |
| 128 }; | 128 }; |
| 129 | 129 |
| 130 // TaskQueue implementation. | 130 // TaskQueue implementation. |
| 131 void UnregisterTaskQueue() override; | 131 void UnregisterTaskQueue() override; |
| 132 bool RunsTasksOnCurrentThread() const override; | 132 bool RunsTasksOnCurrentThread() const override; |
| 133 bool PostDelayedTask(const tracked_objects::Location& from_here, | 133 bool PostDelayedTask(const tracked_objects::Location& from_here, |
| 134 base::Closure task, | 134 base::OnceClosure task, |
| 135 base::TimeDelta delay) override; | 135 base::TimeDelta delay) override; |
| 136 bool PostNonNestableDelayedTask(const tracked_objects::Location& from_here, | 136 bool PostNonNestableDelayedTask(const tracked_objects::Location& from_here, |
| 137 base::Closure task, | 137 base::OnceClosure task, |
| 138 base::TimeDelta delay) override; | 138 base::TimeDelta delay) override; |
| 139 std::unique_ptr<QueueEnabledVoter> CreateQueueEnabledVoter() override; | 139 std::unique_ptr<QueueEnabledVoter> CreateQueueEnabledVoter() override; |
| 140 bool IsQueueEnabled() const override; | 140 bool IsQueueEnabled() const override; |
| 141 bool IsEmpty() const override; | 141 bool IsEmpty() const override; |
| 142 size_t GetNumberOfPendingTasks() const override; | 142 size_t GetNumberOfPendingTasks() const override; |
| 143 bool HasPendingImmediateWork() const override; | 143 bool HasPendingImmediateWork() const override; |
| 144 base::Optional<base::TimeTicks> GetNextScheduledWakeUp() override; | 144 base::Optional<base::TimeTicks> GetNextScheduledWakeUp() override; |
| 145 void SetQueuePriority(QueuePriority priority) override; | 145 void SetQueuePriority(QueuePriority priority) override; |
| 146 QueuePriority GetQueuePriority() const override; | 146 QueuePriority GetQueuePriority() const override; |
| 147 void AddTaskObserver(base::MessageLoop::TaskObserver* task_observer) override; | 147 void AddTaskObserver(base::MessageLoop::TaskObserver* task_observer) override; |
| (...skipping 128 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 276 int is_enabled_refcount; | 276 int is_enabled_refcount; |
| 277 int voter_refcount; | 277 int voter_refcount; |
| 278 base::trace_event::BlameContext* blame_context; // Not owned. | 278 base::trace_event::BlameContext* blame_context; // Not owned. |
| 279 EnqueueOrder current_fence; | 279 EnqueueOrder current_fence; |
| 280 base::TimeTicks scheduled_time_domain_wakeup; | 280 base::TimeTicks scheduled_time_domain_wakeup; |
| 281 }; | 281 }; |
| 282 | 282 |
| 283 ~TaskQueueImpl() override; | 283 ~TaskQueueImpl() override; |
| 284 | 284 |
| 285 bool PostImmediateTaskImpl(const tracked_objects::Location& from_here, | 285 bool PostImmediateTaskImpl(const tracked_objects::Location& from_here, |
| 286 base::Closure task, | 286 base::OnceClosure task, |
| 287 TaskType task_type); | 287 TaskType task_type); |
| 288 bool PostDelayedTaskImpl(const tracked_objects::Location& from_here, | 288 bool PostDelayedTaskImpl(const tracked_objects::Location& from_here, |
| 289 base::Closure task, | 289 base::OnceClosure task, |
| 290 base::TimeDelta delay, | 290 base::TimeDelta delay, |
| 291 TaskType task_type); | 291 TaskType task_type); |
| 292 | 292 |
| 293 // Push the task onto the |delayed_incoming_queue|. Lock-free main thread | 293 // Push the task onto the |delayed_incoming_queue|. Lock-free main thread |
| 294 // only fast path. | 294 // only fast path. |
| 295 void PushOntoDelayedIncomingQueueFromMainThread(Task pending_task, | 295 void PushOntoDelayedIncomingQueueFromMainThread(Task pending_task, |
| 296 base::TimeTicks now); | 296 base::TimeTicks now); |
| 297 | 297 |
| 298 // Push the task onto the |delayed_incoming_queue|. Slow path from other | 298 // Push the task onto the |delayed_incoming_queue|. Slow path from other |
| 299 // threads. | 299 // threads. |
| 300 void PushOntoDelayedIncomingQueueLocked(Task pending_task); | 300 void PushOntoDelayedIncomingQueueLocked(Task pending_task); |
| 301 | 301 |
| 302 void ScheduleDelayedWorkTask(Task pending_task); | 302 void ScheduleDelayedWorkTask(Task pending_task); |
| 303 | 303 |
| 304 void MoveReadyImmediateTasksToImmediateWorkQueueLocked(); | 304 void MoveReadyImmediateTasksToImmediateWorkQueueLocked(); |
| 305 | 305 |
| 306 // Push the task onto the |immediate_incoming_queue| and for auto pumped | 306 // Push the task onto the |immediate_incoming_queue| and for auto pumped |
| 307 // queues it calls MaybePostDoWorkOnMainRunner if the Incoming queue was | 307 // queues it calls MaybePostDoWorkOnMainRunner if the Incoming queue was |
| 308 // empty. | 308 // empty. |
| 309 void PushOntoImmediateIncomingQueueLocked( | 309 void PushOntoImmediateIncomingQueueLocked( |
| 310 const tracked_objects::Location& posted_from, | 310 const tracked_objects::Location& posted_from, |
| 311 base::Closure task, | 311 base::OnceClosure task, |
| 312 base::TimeTicks desired_run_time, | 312 base::TimeTicks desired_run_time, |
| 313 EnqueueOrder sequence_number, | 313 EnqueueOrder sequence_number, |
| 314 bool nestable); | 314 bool nestable); |
| 315 | 315 |
| 316 // Extracts all the tasks from the immediate incoming queue and clears it. | 316 // Extracts all the tasks from the immediate incoming queue and clears it. |
| 317 // Can be called from any thread. | 317 // Can be called from any thread. |
| 318 WTF::Deque<TaskQueueImpl::Task> TakeImmediateIncomingQueue(); | 318 WTF::Deque<TaskQueueImpl::Task> TakeImmediateIncomingQueue(); |
| 319 | 319 |
| 320 void TraceQueueSize() const; | 320 void TraceQueueSize() const; |
| 321 static void QueueAsValueInto(const WTF::Deque<Task>& queue, | 321 static void QueueAsValueInto(const WTF::Deque<Task>& queue, |
| (...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 374 const bool should_report_when_execution_blocked_; | 374 const bool should_report_when_execution_blocked_; |
| 375 | 375 |
| 376 DISALLOW_COPY_AND_ASSIGN(TaskQueueImpl); | 376 DISALLOW_COPY_AND_ASSIGN(TaskQueueImpl); |
| 377 }; | 377 }; |
| 378 | 378 |
| 379 } // namespace internal | 379 } // namespace internal |
| 380 } // namespace scheduler | 380 } // namespace scheduler |
| 381 } // namespace blink | 381 } // namespace blink |
| 382 | 382 |
| 383 #endif // THIRD_PARTY_WEBKIT_SOURCE_PLATFORM_SCHEDULER_BASE_TASK_QUEUE_IMPL_H_ | 383 #endif // THIRD_PARTY_WEBKIT_SOURCE_PLATFORM_SCHEDULER_BASE_TASK_QUEUE_IMPL_H_ |
| OLD | NEW |