Index: base/test/scoped_async_task_scheduler.cc |
diff --git a/base/test/scoped_async_task_scheduler.cc b/base/test/scoped_async_task_scheduler.cc |
index dcc5c15fb1549a4b24f325f5e14851362aba9be2..b48ee82aab8786b5a44a26939bfed7ad446aae41 100644 |
--- a/base/test/scoped_async_task_scheduler.cc |
+++ b/base/test/scoped_async_task_scheduler.cc |
@@ -4,13 +4,9 @@ |
#include "base/test/scoped_async_task_scheduler.h" |
-#include <vector> |
- |
-#include "base/bind.h" |
#include "base/logging.h" |
#include "base/task_scheduler/scheduler_worker_pool_params.h" |
#include "base/task_scheduler/task_scheduler.h" |
-#include "base/task_scheduler/task_scheduler_impl.h" |
namespace base { |
namespace test { |
@@ -19,22 +15,19 @@ ScopedAsyncTaskScheduler::ScopedAsyncTaskScheduler() { |
DCHECK(!TaskScheduler::GetInstance()); |
constexpr int kMaxThreads = 1; |
const TimeDelta kSuggestedReclaimTime = TimeDelta::Max(); |
- std::vector<SchedulerWorkerPoolParams> worker_pool_params_vector; |
- worker_pool_params_vector.emplace_back( |
- "ScopedAsyncTaskScheduler", ThreadPriority::NORMAL, |
+ const SchedulerWorkerPoolParams worker_pool_params{ |
SchedulerWorkerPoolParams::StandbyThreadPolicy::LAZY, kMaxThreads, |
- kSuggestedReclaimTime); |
+ kSuggestedReclaimTime}; |
TaskScheduler::CreateAndSetDefaultTaskScheduler( |
- worker_pool_params_vector, |
- Bind([](const TaskTraits&) -> size_t { return 0; })); |
+ "ScopedAsync", {worker_pool_params, worker_pool_params, |
+ worker_pool_params, worker_pool_params}); |
task_scheduler_ = TaskScheduler::GetInstance(); |
} |
ScopedAsyncTaskScheduler::~ScopedAsyncTaskScheduler() { |
DCHECK_EQ(TaskScheduler::GetInstance(), task_scheduler_); |
TaskScheduler::GetInstance()->Shutdown(); |
- static_cast<internal::TaskSchedulerImpl*>(TaskScheduler::GetInstance()) |
- ->JoinForTesting(); |
+ TaskScheduler::GetInstance()->JoinForTesting(); |
TaskScheduler::SetInstance(nullptr); |
} |