| Index: base/task_scheduler/task_scheduler_impl.cc
|
| diff --git a/base/task_scheduler/task_scheduler_impl.cc b/base/task_scheduler/task_scheduler_impl.cc
|
| index 01786493748a967f9901b206245d2bb5879f05c0..b31f6061a40be529141c421031340ec0950314d5 100644
|
| --- a/base/task_scheduler/task_scheduler_impl.cc
|
| +++ b/base/task_scheduler/task_scheduler_impl.cc
|
| @@ -6,8 +6,6 @@
|
|
|
| #include <utility>
|
|
|
| -#include "base/bind.h"
|
| -#include "base/bind_helpers.h"
|
| #include "base/memory/ptr_util.h"
|
| #include "base/task_scheduler/delayed_task_manager.h"
|
| #include "base/task_scheduler/scheduler_single_thread_task_runner_manager.h"
|
| @@ -196,12 +194,6 @@ void TaskSchedulerImpl::Initialize(
|
| task_tracker_.get(), delayed_task_manager_.get());
|
| single_thread_task_runner_manager_->Start();
|
|
|
| - // Callback invoked by workers to re-enqueue a sequence in the appropriate
|
| - // PriorityQueue.
|
| - const SchedulerWorkerPoolImpl::ReEnqueueSequenceCallback
|
| - re_enqueue_sequence_callback =
|
| - Bind(&TaskSchedulerImpl::ReEnqueueSequenceCallback, Unretained(this));
|
| -
|
| // Order must match the EnvironmentType enum.
|
| const SchedulerWorkerPoolParams* worker_pool_params[] = {
|
| &init_params.background_worker_pool_params,
|
| @@ -226,8 +218,7 @@ void TaskSchedulerImpl::Initialize(
|
| // deleted before all its worker pools have been joined.
|
| worker_pools_[environment_type] = MakeUnique<SchedulerWorkerPoolImpl>(
|
| name_ + kEnvironmentParams[environment_type].name_suffix,
|
| - kEnvironmentParams[environment_type].priority_hint,
|
| - re_enqueue_sequence_callback, task_tracker_.get(),
|
| + kEnvironmentParams[environment_type].priority_hint, task_tracker_.get(),
|
| delayed_task_manager_.get());
|
| worker_pools_[environment_type]->Start(
|
| *worker_pool_params[environment_type]);
|
| @@ -239,21 +230,5 @@ SchedulerWorkerPoolImpl* TaskSchedulerImpl::GetWorkerPoolForTraits(
|
| return worker_pools_[GetEnvironmentIndexForTraits(traits)].get();
|
| }
|
|
|
| -void TaskSchedulerImpl::ReEnqueueSequenceCallback(
|
| - scoped_refptr<Sequence> sequence) {
|
| - DCHECK(sequence);
|
| -
|
| - const SequenceSortKey sort_key = sequence->GetSortKey();
|
| -
|
| - // The next task in |sequence| should run in a worker pool suited for its
|
| - // traits, except for the priority which is adjusted to the highest priority
|
| - // in |sequence|.
|
| - const TaskTraits traits =
|
| - sequence->PeekTaskTraits().WithPriority(sort_key.priority());
|
| -
|
| - GetWorkerPoolForTraits(traits)->ReEnqueueSequence(std::move(sequence),
|
| - sort_key);
|
| -}
|
| -
|
| } // namespace internal
|
| } // namespace base
|
|
|