| 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..70c80054f621a398707331e8d12d8a07fd8c751f 100644
|
| --- a/base/task_scheduler/task_scheduler_impl.cc
|
| +++ b/base/task_scheduler/task_scheduler_impl.cc
|
| @@ -186,14 +186,13 @@ void TaskSchedulerImpl::Initialize(
|
| base::MakeUnique<TaskTracker>();
|
| #endif
|
|
|
| - // Instantiate DelayedTaskManager. Needs to happen after starting the service
|
| - // thread to get its task_runner().
|
| - delayed_task_manager_ =
|
| - base::MakeUnique<DelayedTaskManager>(service_thread_.task_runner());
|
| + // Start DelayedTaskManager. Needs to happen after starting the service thread
|
| + // to get its task_runner().
|
| + delayed_task_manager_.Start(service_thread_.task_runner());
|
|
|
| single_thread_task_runner_manager_ =
|
| MakeUnique<SchedulerSingleThreadTaskRunnerManager>(
|
| - task_tracker_.get(), delayed_task_manager_.get());
|
| + task_tracker_.get(), &delayed_task_manager_);
|
| single_thread_task_runner_manager_->Start();
|
|
|
| // Callback invoked by workers to re-enqueue a sequence in the appropriate
|
| @@ -228,7 +227,7 @@ void TaskSchedulerImpl::Initialize(
|
| name_ + kEnvironmentParams[environment_type].name_suffix,
|
| kEnvironmentParams[environment_type].priority_hint,
|
| re_enqueue_sequence_callback, task_tracker_.get(),
|
| - delayed_task_manager_.get());
|
| + &delayed_task_manager_);
|
| worker_pools_[environment_type]->Start(
|
| *worker_pool_params[environment_type]);
|
| }
|
|
|