| Index: components/scheduler/child/task_queue_impl.h
|
| diff --git a/components/scheduler/child/task_queue_impl.h b/components/scheduler/child/task_queue_impl.h
|
| index 4cd341ca3a696cec7305da8c438e681dbbddb1ee..7aef6caf46c722c74789aea707726ed656865294 100644
|
| --- a/components/scheduler/child/task_queue_impl.h
|
| +++ b/components/scheduler/child/task_queue_impl.h
|
| @@ -78,6 +78,9 @@ class SCHEDULER_EXPORT TaskQueueImpl final : public TaskQueue {
|
| void SetQueuePriority(QueuePriority priority) override;
|
| void PumpQueue() override;
|
| void SetPumpPolicy(PumpPolicy pump_policy) override;
|
| + void AddTaskObserver(base::MessageLoop::TaskObserver* task_observer) override;
|
| + void RemoveTaskObserver(
|
| + base::MessageLoop::TaskObserver* task_observer) override;
|
|
|
| bool NextPendingDelayedTaskRunTime(
|
| base::TimeTicks* next_pending_delayed_task);
|
| @@ -110,6 +113,9 @@ class SCHEDULER_EXPORT TaskQueueImpl final : public TaskQueue {
|
| bool GetQuiescenceMonitored() const { return should_monitor_quiescence_; }
|
| bool GetShouldNotifyObservers() const { return should_notify_observers_; }
|
|
|
| + void NotifyWillProcessTask(const base::PendingTask& pending_task);
|
| + void NotifyDidProcessTask(const base::PendingTask& pending_task);
|
| +
|
| // Delayed task posted to the underlying run loop, which locks |lock_| and
|
| // calls MoveReadyDelayedTasksToIncomingQueueLocked to process dealyed tasks
|
| // that need to be run now. Thread safe, but in practice it's always called
|
| @@ -191,6 +197,7 @@ class SCHEDULER_EXPORT TaskQueueImpl final : public TaskQueue {
|
|
|
| base::ThreadChecker main_thread_checker_;
|
| std::queue<Task> work_queue_;
|
| + base::ObserverList<base::MessageLoop::TaskObserver> task_observers_;
|
| WakeupPolicy wakeup_policy_;
|
| size_t set_index_;
|
| bool should_monitor_quiescence_;
|
|
|