Remove SchedulerWorkerPoolImpl::ReEnqueueSequenceCallback.

base/task_scheduler/scheduler_worker_pool_impl.h

 // Copyright 2016 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.
 
 #ifndef BASE_TASK_SCHEDULER_SCHEDULER_WORKER_POOL_IMPL_H_
 #define BASE_TASK_SCHEDULER_SCHEDULER_WORKER_POOL_IMPL_H_
 
 #include <stddef.h>
 
 #include <memory>
 #include <string>
 #include <vector>
 
 #include "base/base_export.h"
-#include "base/callback.h"
 #include "base/logging.h"
 #include "base/macros.h"
 #include "base/memory/ref_counted.h"
 #include "base/synchronization/atomic_flag.h"
 #include "base/synchronization/condition_variable.h"
 #include "base/task_scheduler/priority_queue.h"
 #include "base/task_scheduler/scheduler_lock.h"
 #include "base/task_scheduler/scheduler_worker.h"
 #include "base/task_scheduler/scheduler_worker_pool.h"
 #include "base/task_scheduler/scheduler_worker_stack.h"
 #include "base/task_scheduler/sequence.h"
 #include "base/task_scheduler/task.h"
 #include "base/time/time.h"
 
 namespace base {
 
 class HistogramBase;
 class SchedulerWorkerPoolParams;
 class TaskTraits;
 
 namespace internal {
 
 class DelayedTaskManager;
 class TaskTracker;
 
 // A pool of workers that run Tasks. This class is thread-safe.
 class BASE_EXPORT SchedulerWorkerPoolImpl : public SchedulerWorkerPool {
  public:
-  // Callback invoked when a Sequence isn't empty after a worker pops a Task
-  // from it.
-  using ReEnqueueSequenceCallback = Callback<void(scoped_refptr<Sequence>)>;
-
   // Constructs a pool without workers. Tasks can be posted to the pool, but
   // they won't run until workers are created. To create workers and start
   // running tasks, call Start().
   //
   // |name| is used to label the pool's threads ("TaskScheduler" + |name| +
   // index) and histograms ("TaskScheduler." + histogram name + "." + |name| +
   // extra suffixes). |priority_hint| is the preferred thread priority; the
   // actual thread priority depends on shutdown state and platform capabilities.
-  // |re_enqueue_sequence_callback| is invoked when a Sequence isn't empty after
-  // a worker pops a Task from it. |task_tracker| keeps track of tasks.
-  // |delayed_task_manager| handles tasks posted with a delay.
+  // |task_tracker| keeps track of tasks. |delayed_task_manager| handles tasks
+  // posted with a delay.
   SchedulerWorkerPoolImpl(
       const std::string& name,
       ThreadPriority priority_hint,
-      ReEnqueueSequenceCallback re_enqueue_sequence_callback,
       TaskTracker* task_tracker,
       DelayedTaskManager* delayed_task_manager);
 
   // Creates workers following the |params| specification, allowing existing and
   // future tasks to run. Can only be called once. CHECKs on failure.
   void Start(const SchedulerWorkerPoolParams& params);
 
   // Destroying a SchedulerWorkerPoolImpl returned by Create() is not allowed in
   // production; it is always leaked. In tests, it can only be destroyed after
   // JoinForTesting() has returned.
   ~SchedulerWorkerPoolImpl() override;
 
   // SchedulerWorkerPool:
   scoped_refptr<TaskRunner> CreateTaskRunnerWithTraits(
       const TaskTraits& traits) override;
   scoped_refptr<SequencedTaskRunner> CreateSequencedTaskRunnerWithTraits(
       const TaskTraits& traits) override;
-  void ReEnqueueSequence(scoped_refptr<Sequence> sequence,
-                         const SequenceSortKey& sequence_sort_key) override;
   bool PostTaskWithSequence(std::unique_ptr<Task> task,
                             scoped_refptr<Sequence> sequence) override;
   void PostTaskWithSequenceNow(std::unique_ptr<Task> task,
                                scoped_refptr<Sequence> sequence) override;
 
   const HistogramBase* num_tasks_before_detach_histogram() const {
     return num_tasks_before_detach_histogram_;
   }
 
   const HistogramBase* num_tasks_between_waits_histogram() const {
@@ skipping 41 matching lines @@
   const SchedulerWorker* PeekAtIdleWorkersStack() const;
 
   // Removes |worker| from |idle_workers_stack_|.
   void RemoveFromIdleWorkersStack(SchedulerWorker* worker);
 
   // Returns true if worker thread detachment is permitted.
   bool CanWorkerDetachForTesting();
 
   const std::string name_;
   const ThreadPriority priority_hint_;
-  const ReEnqueueSequenceCallback re_enqueue_sequence_callback_;
 
   // PriorityQueue from which all threads of this worker pool get work.
   PriorityQueue shared_priority_queue_;
 
   // All workers owned by this worker pool. Initialized by Start() within the
   // scope of |idle_workers_stack_lock_|. Never modified afterwards (i.e. can be
   // read without synchronization once |workers_created_.IsSet()|).
   std::vector<scoped_refptr<SchedulerWorker>> workers_;
 
   // Suggested reclaim time for workers. Initialized by Start(). Never modified
@@ skipping 50 matching lines @@
   TaskTracker* const task_tracker_;
   DelayedTaskManager* const delayed_task_manager_;
 
   DISALLOW_COPY_AND_ASSIGN(SchedulerWorkerPoolImpl);
 };
 
 }  // namespace internal
 }  // namespace base
 
 #endif  // BASE_TASK_SCHEDULER_SCHEDULER_WORKER_POOL_IMPL_H_