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 |