Remove after wakeup logic and replace PumpTask with Fences

third_party/WebKit/Source/platform/scheduler/child/scheduler_helper.cc

 // Copyright 2015 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "platform/scheduler/child/scheduler_helper.h"
 
 #include "base/time/default_tick_clock.h"
 #include "base/trace_event/trace_event.h"
 #include "base/trace_event/trace_event_argument.h"
 #include "platform/scheduler/base/task_queue_impl.h"
 #include "platform/scheduler/child/scheduler_tqm_delegate.h"
 
 namespace blink {
 namespace scheduler {
 
 SchedulerHelper::SchedulerHelper(
     scoped_refptr<SchedulerTqmDelegate> task_queue_manager_delegate,
     const char* tracing_category,
     const char* disabled_by_default_tracing_category,
     const char* disabled_by_default_verbose_tracing_category)
     : task_queue_manager_delegate_(task_queue_manager_delegate),
       task_queue_manager_(
           new TaskQueueManager(task_queue_manager_delegate,
                                tracing_category,
                                disabled_by_default_tracing_category,
                                disabled_by_default_verbose_tracing_category)),
       control_task_runner_(NewTaskQueue(
-          TaskQueue::Spec("control_tq")
-              .SetWakeupPolicy(TaskQueue::WakeupPolicy::DONT_WAKE_OTHER_QUEUES)
-              .SetShouldNotifyObservers(false))),
-      control_after_wakeup_task_runner_(NewTaskQueue(
-          TaskQueue::Spec("control_after_wakeup_tq")
-              .SetPumpPolicy(TaskQueue::PumpPolicy::AFTER_WAKEUP)
-              .SetWakeupPolicy(TaskQueue::WakeupPolicy::DONT_WAKE_OTHER_QUEUES)
-              .SetShouldNotifyObservers(false))),
+          TaskQueue::Spec("control_tq").SetShouldNotifyObservers(false))),
       default_task_runner_(NewTaskQueue(
           TaskQueue::Spec("default_tq").SetShouldMonitorQuiescence(true))),
       observer_(nullptr),
       tracing_category_(tracing_category),
       disabled_by_default_tracing_category_(
           disabled_by_default_tracing_category) {
   control_task_runner_->SetQueuePriority(TaskQueue::CONTROL_PRIORITY);
-  control_after_wakeup_task_runner_->SetQueuePriority(
-      TaskQueue::CONTROL_PRIORITY);
 
   task_queue_manager_->SetWorkBatchSize(4);
 
   DCHECK(task_queue_manager_delegate_);
   task_queue_manager_delegate_->SetDefaultTaskRunner(
       default_task_runner_.get());
 }
 
 SchedulerHelper::~SchedulerHelper() {
   Shutdown();
@@ skipping 15 matching lines @@
 
 scoped_refptr<TaskQueue> SchedulerHelper::DefaultTaskRunner() {
   CheckOnValidThread();
   return default_task_runner_;
 }
 
 scoped_refptr<TaskQueue> SchedulerHelper::ControlTaskRunner() {
   return control_task_runner_;
 }
 
-scoped_refptr<TaskQueue> SchedulerHelper::ControlAfterWakeUpTaskRunner() {
-  return control_after_wakeup_task_runner_;
-}
 
 void SchedulerHelper::SetWorkBatchSizeForTesting(size_t work_batch_size) {
   CheckOnValidThread();
   DCHECK(task_queue_manager_.get());
   task_queue_manager_->SetWorkBatchSize(work_batch_size);
 }
 
 TaskQueueManager* SchedulerHelper::GetTaskQueueManagerForTesting() {
   CheckOnValidThread();
   return task_queue_manager_.get();
@@ skipping 63 matching lines @@
 }
 
 TaskQueue* SchedulerHelper::CurrentlyExecutingTaskQueue() const {
   if (!task_queue_manager_)
     return nullptr;
   return task_queue_manager_->currently_executing_task_queue();
 }
 
 }  // namespace scheduler
 }  // namespace blink