Index: base/task_scheduler/scheduler_worker_pool_impl.cc |
diff --git a/base/task_scheduler/scheduler_worker_pool_impl.cc b/base/task_scheduler/scheduler_worker_pool_impl.cc |
index 56e1f7b54eb5e55522e94f047dddf0a7333a62ee..75bc35ae45d46f16f27ee8b2618ff9cdb441c189 100644 |
--- a/base/task_scheduler/scheduler_worker_pool_impl.cc |
+++ b/base/task_scheduler/scheduler_worker_pool_impl.cc |
@@ -199,14 +199,18 @@ SchedulerWorkerPoolImpl::~SchedulerWorkerPoolImpl() { |
// static |
std::unique_ptr<SchedulerWorkerPoolImpl> SchedulerWorkerPoolImpl::Create( |
+ const std::string& name, |
+ ThreadPriority priority_hint, |
const SchedulerWorkerPoolParams& params, |
const ReEnqueueSequenceCallback& re_enqueue_sequence_callback, |
TaskTracker* task_tracker, |
DelayedTaskManager* delayed_task_manager) { |
- auto worker_pool = WrapUnique( |
- new SchedulerWorkerPoolImpl(params, task_tracker, delayed_task_manager)); |
- if (worker_pool->Initialize(params, re_enqueue_sequence_callback)) |
+ auto worker_pool = WrapUnique(new SchedulerWorkerPoolImpl( |
+ name, params, task_tracker, delayed_task_manager)); |
+ if (worker_pool->Initialize(priority_hint, params, |
+ re_enqueue_sequence_callback)) { |
return worker_pool; |
+ } |
return nullptr; |
} |
@@ -464,10 +468,11 @@ void SchedulerWorkerPoolImpl::SchedulerWorkerDelegateImpl::OnDetach() { |
} |
SchedulerWorkerPoolImpl::SchedulerWorkerPoolImpl( |
+ const std::string& name, |
const SchedulerWorkerPoolParams& params, |
TaskTracker* task_tracker, |
DelayedTaskManager* delayed_task_manager) |
- : name_(params.name()), |
+ : name_(name), |
suggested_reclaim_time_(params.suggested_reclaim_time()), |
idle_workers_stack_lock_(shared_priority_queue_.container_lock()), |
idle_workers_stack_cv_for_testing_( |
@@ -511,6 +516,7 @@ SchedulerWorkerPoolImpl::SchedulerWorkerPoolImpl( |
} |
bool SchedulerWorkerPoolImpl::Initialize( |
+ ThreadPriority priority_hint, |
const SchedulerWorkerPoolParams& params, |
const ReEnqueueSequenceCallback& re_enqueue_sequence_callback) { |
AutoSchedulerLock auto_lock(idle_workers_stack_lock_); |
@@ -530,7 +536,7 @@ bool SchedulerWorkerPoolImpl::Initialize( |
? SchedulerWorker::InitialState::ALIVE |
: SchedulerWorker::InitialState::DETACHED; |
scoped_refptr<SchedulerWorker> worker = SchedulerWorker::Create( |
- params.priority_hint(), |
+ priority_hint, |
MakeUnique<SchedulerWorkerDelegateImpl>( |
this, re_enqueue_sequence_callback, index), |
task_tracker_, initial_state, params.backward_compatibility()); |