Index: content/browser/browser_main_loop.cc |
diff --git a/content/browser/browser_main_loop.cc b/content/browser/browser_main_loop.cc |
index 86a5d31e2073c47e72ef333a56bdd18084e8d28e..dba4e48372aaecd6c8da7cffddd93da1197e45e7 100644 |
--- a/content/browser/browser_main_loop.cc |
+++ b/content/browser/browser_main_loop.cc |
@@ -31,6 +31,8 @@ |
#include "base/strings/string_number_conversions.h" |
#include "base/strings/string_split.h" |
#include "base/system_monitor/system_monitor.h" |
+#include "base/task_scheduler/scheduler_worker_pool_params.h" |
+#include "base/task_scheduler/task_scheduler.h" |
#include "base/threading/sequenced_worker_pool.h" |
#include "base/threading/thread_restrictions.h" |
#include "base/threading/thread_task_runner_handle.h" |
@@ -870,6 +872,17 @@ void BrowserMainLoop::CreateStartupTasks() { |
int BrowserMainLoop::CreateThreads() { |
TRACE_EVENT0("startup,rail", "BrowserMainLoop::CreateThreads"); |
+ std::vector<base::SchedulerWorkerPoolParams> params_vector; |
+ base::TaskScheduler::WorkerPoolIndexForTraitsCallback |
+ index_to_traits_callback; |
+ GetContentClient()->browser()->GetTaskSchedulerInitializationParams( |
+ ¶ms_vector, &index_to_traits_callback); |
+ |
+ base::TaskScheduler::CreateAndSetDefaultTaskScheduler( |
+ params_vector, index_to_traits_callback); |
+ |
+ GetContentClient()->browser()->PerformRedirectionToTaskScheduler(); |
+ |
base::Thread::Options io_message_loop_options; |
io_message_loop_options.message_loop_type = base::MessageLoop::TYPE_IO; |
base::Thread::Options ui_message_loop_options; |
@@ -1199,6 +1212,10 @@ void BrowserMainLoop::ShutdownThreadsAndCleanUp() { |
URLDataManager::DeleteDataSources(); |
} |
+ base::TaskScheduler* task_scheduler = base::TaskScheduler::GetInstance(); |
fdoray
2016/12/01 15:26:21
There should always be a TaskScheduler.
robliao
2016/12/06 01:31:30
Done.
|
+ if (task_scheduler) |
+ task_scheduler->Shutdown(); |
+ |
if (parts_) { |
TRACE_EVENT0("shutdown", "BrowserMainLoop::Subsystem:PostDestroyThreads"); |
parts_->PostDestroyThreads(); |