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 47f9bbc83a02dfb3bc2b5c0353ec71c2fcbee141..d648b9d4628fab6324b9e8474daffa607692f0d8 100644 |
--- a/base/task_scheduler/delayed_task_manager.cc |
+++ b/base/task_scheduler/delayed_task_manager.cc |
@@ -15,12 +15,12 @@ namespace internal { |
struct DelayedTaskManager::DelayedTask { |
DelayedTask(std::unique_ptr<Task> task, |
scoped_refptr<Sequence> sequence, |
- SchedulerWorkerThread* worker_thread, |
+ SchedulerWorker* worker, |
SchedulerWorkerPool* worker_pool, |
uint64_t index) |
: task(std::move(task)), |
sequence(std::move(sequence)), |
- worker_thread(worker_thread), |
+ worker(worker), |
worker_pool(worker_pool), |
index(index) {} |
@@ -30,11 +30,11 @@ struct DelayedTaskManager::DelayedTask { |
DelayedTask& operator=(DelayedTask&& other) = default; |
- // |task| will be posted to |worker_pool| with |sequence| and |worker_thread| |
+ // |task| will be posted to |worker_pool| with |sequence| and |worker| |
// when it becomes ripe for execution. |
std::unique_ptr<Task> task; |
scoped_refptr<Sequence> sequence; |
- SchedulerWorkerThread* worker_thread; |
+ SchedulerWorker* worker; |
SchedulerWorkerPool* worker_pool; |
// Ensures that tasks that have the same |delayed_run_time| are sorted |
@@ -55,7 +55,7 @@ DelayedTaskManager::~DelayedTaskManager() = default; |
void DelayedTaskManager::AddDelayedTask(std::unique_ptr<Task> task, |
scoped_refptr<Sequence> sequence, |
- SchedulerWorkerThread* worker_thread, |
+ SchedulerWorker* worker, |
SchedulerWorkerPool* worker_pool) { |
DCHECK(task); |
DCHECK(sequence); |
@@ -70,7 +70,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), worker_thread, |
+ delayed_tasks_.emplace(std::move(task), std::move(sequence), worker, |
worker_pool, ++delayed_task_index_); |
} |
@@ -105,7 +105,7 @@ void DelayedTaskManager::PostReadyTasks() { |
for (auto& delayed_task : ready_tasks) { |
delayed_task.worker_pool->PostTaskWithSequenceNow( |
std::move(delayed_task.task), std::move(delayed_task.sequence), |
- delayed_task.worker_thread); |
+ delayed_task.worker); |
} |
} |