| Index: base/task_scheduler/delayed_task_manager.cc
|
| diff --git a/base/task_scheduler/delayed_task_manager.cc b/base/task_scheduler/delayed_task_manager.cc
|
| index 1b2782965e3e8366bc459810c33899a8738d1188..0b8c2f9a4b7612c5bd25cd3fdc170f92e57f43c6 100644
|
| --- a/base/task_scheduler/delayed_task_manager.cc
|
| +++ b/base/task_scheduler/delayed_task_manager.cc
|
| @@ -7,7 +7,7 @@
|
| #include <utility>
|
|
|
| #include "base/logging.h"
|
| -#include "base/task_scheduler/scheduler_task_executor.h"
|
| +#include "base/task_scheduler/scheduler_thread_pool.h"
|
|
|
| namespace base {
|
| namespace internal {
|
| @@ -15,11 +15,11 @@ namespace internal {
|
| struct DelayedTaskManager::DelayedTask {
|
| DelayedTask(std::unique_ptr<Task> task,
|
| scoped_refptr<Sequence> sequence,
|
| - SchedulerTaskExecutor* executor,
|
| + SchedulerThreadPool* thread_pool,
|
| uint64_t index)
|
| : task(std::move(task)),
|
| sequence(std::move(sequence)),
|
| - executor(executor),
|
| + thread_pool(thread_pool),
|
| index(index) {}
|
|
|
| DelayedTask(DelayedTask&& other) = default;
|
| @@ -28,11 +28,11 @@ struct DelayedTaskManager::DelayedTask {
|
|
|
| DelayedTask& operator=(DelayedTask&& other) = default;
|
|
|
| - // |task| will be posted to |executor| as part of |sequence| when it becomes
|
| - // ripe for execution.
|
| + // |task| will be posted to |thread_pool| as part of |sequence| when it
|
| + // becomes ripe for execution.
|
| std::unique_ptr<Task> task;
|
| scoped_refptr<Sequence> sequence;
|
| - SchedulerTaskExecutor* executor;
|
| + SchedulerThreadPool* thread_pool;
|
|
|
| // Ensures that tasks that have the same |delayed_run_time| are sorted
|
| // according to the order in which they were added to the DelayedTaskManager.
|
| @@ -52,10 +52,10 @@ DelayedTaskManager::~DelayedTaskManager() = default;
|
|
|
| void DelayedTaskManager::AddDelayedTask(std::unique_ptr<Task> task,
|
| scoped_refptr<Sequence> sequence,
|
| - SchedulerTaskExecutor* executor) {
|
| + SchedulerThreadPool* thread_pool) {
|
| DCHECK(task);
|
| DCHECK(sequence);
|
| - DCHECK(executor);
|
| + DCHECK(thread_pool);
|
|
|
| const TimeTicks new_task_delayed_run_time = task->delayed_run_time;
|
| TimeTicks current_delayed_run_time;
|
| @@ -66,7 +66,7 @@ void DelayedTaskManager::AddDelayedTask(std::unique_ptr<Task> task,
|
| if (!delayed_tasks_.empty())
|
| current_delayed_run_time = delayed_tasks_.top().task->delayed_run_time;
|
|
|
| - delayed_tasks_.emplace(std::move(task), std::move(sequence), executor,
|
| + delayed_tasks_.emplace(std::move(task), std::move(sequence), thread_pool,
|
| ++delayed_task_index_);
|
| }
|
|
|
| @@ -99,7 +99,7 @@ void DelayedTaskManager::PostReadyTasks() {
|
|
|
| // Post delayed tasks that are ready for execution.
|
| for (auto& delayed_task : ready_tasks) {
|
| - delayed_task.executor->PostTaskWithSequence(
|
| + delayed_task.thread_pool->PostTaskWithSequenceNow(
|
| std::move(delayed_task.task), std::move(delayed_task.sequence));
|
| }
|
| }
|
|
|