Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "base/task_scheduler/task_scheduler_impl.h" | 5 #include "base/task_scheduler/task_scheduler_impl.h" |
| 6 | 6 |
| 7 #include <utility> | 7 #include <utility> |
| 8 | 8 |
| 9 #include "base/bind.h" | 9 #include "base/bind.h" |
| 10 #include "base/bind_helpers.h" | 10 #include "base/bind_helpers.h" |
| (...skipping 222 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 233 | 233 |
| 234 // Instantiate DelayedTaskManager. Needs to happen after starting the service | 234 // Instantiate DelayedTaskManager. Needs to happen after starting the service |
| 235 // thread to get its task_runner(). | 235 // thread to get its task_runner(). |
| 236 delayed_task_manager_ = | 236 delayed_task_manager_ = |
| 237 base::MakeUnique<DelayedTaskManager>(service_thread_.task_runner()); | 237 base::MakeUnique<DelayedTaskManager>(service_thread_.task_runner()); |
| 238 | 238 |
| 239 single_thread_task_runner_manager_ = | 239 single_thread_task_runner_manager_ = |
| 240 MakeUnique<SchedulerSingleThreadTaskRunnerManager>( | 240 MakeUnique<SchedulerSingleThreadTaskRunnerManager>( |
| 241 worker_pool_params_vector, worker_pool_index_for_traits_callback_, | 241 worker_pool_params_vector, worker_pool_index_for_traits_callback_, |
| 242 task_tracker_.get(), delayed_task_manager_.get()); | 242 task_tracker_.get(), delayed_task_manager_.get()); |
| 243 single_thread_task_runner_manager_->Start(); | |
|
gab
2017/04/10 18:04:56
Just checking: does anything break down if we forg
fdoray
2017/04/10 19:05:00
TaskSchedulerImplTest.MultipleTraitsExecutionModeP
| |
| 243 | 244 |
| 244 // Callback invoked by workers to re-enqueue a sequence in the appropriate | 245 // Callback invoked by workers to re-enqueue a sequence in the appropriate |
| 245 // PriorityQueue. | 246 // PriorityQueue. |
| 246 const SchedulerWorkerPoolImpl::ReEnqueueSequenceCallback | 247 const SchedulerWorkerPoolImpl::ReEnqueueSequenceCallback |
| 247 re_enqueue_sequence_callback = | 248 re_enqueue_sequence_callback = |
| 248 Bind(&TaskSchedulerImpl::ReEnqueueSequenceCallback, Unretained(this)); | 249 Bind(&TaskSchedulerImpl::ReEnqueueSequenceCallback, Unretained(this)); |
| 249 | 250 |
| 250 // Start worker pools. | 251 // Start worker pools. |
| 251 for (const auto& worker_pool_params : worker_pool_params_vector) { | 252 for (const auto& worker_pool_params : worker_pool_params_vector) { |
| 252 // Passing pointers to objects owned by |this| to | 253 // Passing pointers to objects owned by |this| to |
| (...skipping 25 matching lines...) Expand all Loading... | |
| 278 // in |sequence|. | 279 // in |sequence|. |
| 279 const TaskTraits traits = | 280 const TaskTraits traits = |
| 280 sequence->PeekTaskTraits().WithPriority(sort_key.priority()); | 281 sequence->PeekTaskTraits().WithPriority(sort_key.priority()); |
| 281 | 282 |
| 282 GetWorkerPoolForTraits(traits)->ReEnqueueSequence(std::move(sequence), | 283 GetWorkerPoolForTraits(traits)->ReEnqueueSequence(std::move(sequence), |
| 283 sort_key); | 284 sort_key); |
| 284 } | 285 } |
| 285 | 286 |
| 286 } // namespace internal | 287 } // namespace internal |
| 287 } // namespace base | 288 } // namespace base |
| OLD | NEW |