Lines Matching refs:task
35 for (HeapTask* task : tasks_) { in ~TaskProcessor()
36 task->Finalize(); in ~TaskProcessor()
41 void TaskProcessor::AddTask(Thread* self, HeapTask* task) { in AddTask() argument
44 tasks_.insert(task); in AddTask()
60 HeapTask* task = *tasks_.begin(); in GetTask() local
63 uint64_t target_time = task->GetTargetRunTime(); in GetTask()
66 return task; in GetTask()
79 void TaskProcessor::UpdateTargetRunTime(Thread* self, HeapTask* task, uint64_t new_target_time) { in UpdateTargetRunTime() argument
82 auto range = tasks_.equal_range(task); in UpdateTargetRunTime()
84 if (*it == task) { in UpdateTargetRunTime()
86 if (new_target_time != task->GetTargetRunTime()) { in UpdateTargetRunTime()
88 task->SetTargetRunTime(new_target_time); in UpdateTargetRunTime()
89 tasks_.insert(task); in UpdateTargetRunTime()
92 if (*tasks_.begin() == task) { in UpdateTargetRunTime()
127 HeapTask* task = GetTask(self); in RunAllTasks() local
128 if (task != nullptr) { in RunAllTasks()
129 task->Run(self); in RunAllTasks()
130 task->Finalize(); in RunAllTasks()