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 06933eb32db62386195ba3619fd71c03914346fd..604bcc02e73d9d61c05711e2250333190b4fc00f 100644 |
--- a/base/task_scheduler/scheduler_worker_pool_impl.cc |
+++ b/base/task_scheduler/scheduler_worker_pool_impl.cc |
@@ -18,6 +18,7 @@ |
#include "base/strings/stringprintf.h" |
#include "base/task_scheduler/delayed_task_manager.h" |
#include "base/task_scheduler/task_tracker.h" |
+#include "base/task_scheduler/worker_pool_params.h" |
#include "base/threading/platform_thread.h" |
#include "base/threading/thread_local.h" |
#include "base/threading/thread_restrictions.h" |
@@ -227,17 +228,16 @@ SchedulerWorkerPoolImpl::~SchedulerWorkerPoolImpl() { |
// static |
std::unique_ptr<SchedulerWorkerPoolImpl> SchedulerWorkerPoolImpl::Create( |
- StringPiece name, |
- ThreadPriority thread_priority, |
- size_t max_threads, |
- IORestriction io_restriction, |
+ const WorkerPoolParams& params, |
const ReEnqueueSequenceCallback& re_enqueue_sequence_callback, |
TaskTracker* task_tracker, |
DelayedTaskManager* delayed_task_manager) { |
std::unique_ptr<SchedulerWorkerPoolImpl> worker_pool( |
- new SchedulerWorkerPoolImpl(name, io_restriction, task_tracker, |
- delayed_task_manager)); |
- if (worker_pool->Initialize(thread_priority, max_threads, |
+ new SchedulerWorkerPoolImpl(params.name(), |
+ params.io_restriction(), |
+ task_tracker, delayed_task_manager)); |
+ if (worker_pool->Initialize(params.thread_priority(), |
+ params.max_threads(), |
re_enqueue_sequence_callback)) { |
return worker_pool; |
} |