Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(40)

Unified Diff: base/task_scheduler/task_scheduler_impl.cc

Issue 2686593003: DESIGN DISCUSSION ONLY Task Scheduler Single Thread Task Runner Manager for Dedicated Threads per S… (Closed)
Patch Set: Wait for Detached Thread to Complete Created 3 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
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 6157635514c193ae14a60fb5f300023a66e78e36..d4f77dc904c7efd188a99a257d4434a254c1facf 100644
--- a/base/task_scheduler/task_scheduler_impl.cc
+++ b/base/task_scheduler/task_scheduler_impl.cc
@@ -10,6 +10,7 @@
#include "base/bind_helpers.h"
#include "base/memory/ptr_util.h"
#include "base/task_scheduler/delayed_task_manager.h"
+#include "base/task_scheduler/scheduler_single_thread_task_runner_manager.h"
#include "base/task_scheduler/scheduler_worker_pool_params.h"
#include "base/task_scheduler/sequence_sort_key.h"
#include "base/task_scheduler/task.h"
@@ -66,8 +67,8 @@ TaskSchedulerImpl::CreateSequencedTaskRunnerWithTraits(
scoped_refptr<SingleThreadTaskRunner>
TaskSchedulerImpl::CreateSingleThreadTaskRunnerWithTraits(
const TaskTraits& traits) {
- return GetWorkerPoolForTraits(traits)->CreateSingleThreadTaskRunnerWithTraits(
- traits);
+ return single_thread_task_runner_manager_
+ ->CreateSingleThreadTaskRunnerWithTraits(traits);
}
std::vector<const HistogramBase*> TaskSchedulerImpl::GetHistograms() const {
@@ -148,6 +149,11 @@ void TaskSchedulerImpl::Initialize(
delayed_task_manager_ =
base::MakeUnique<DelayedTaskManager>(service_thread_.task_runner());
+ single_thread_task_runner_manager_ =
+ MakeUnique<SchedulerSingleThreadTaskRunnerManager>(
+ worker_pool_params_vector, worker_pool_index_for_traits_callback_,
+ task_tracker_.get(), delayed_task_manager_.get());
+
// Callback invoked by workers to re-enqueue a sequence in the appropriate
// PriorityQueue.
const SchedulerWorkerPoolImpl::ReEnqueueSequenceCallback
« base/task_scheduler/scheduler_worker_unittest.cc ('K') | « base/task_scheduler/task_scheduler_impl.h ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698