Lines Matching defs:TaskProcessor
25 TaskProcessor::TaskProcessor()
32 TaskProcessor::~TaskProcessor() {
34 LOG(WARNING) << "TaskProcessor: Finalizing " << tasks_.size() << " unprocessed tasks.";
41 void TaskProcessor::AddTask(Thread* self, HeapTask* task) {
48 HeapTask* TaskProcessor::GetTask(Thread* self) {
79 void TaskProcessor::UpdateTargetRunTime(Thread* self, HeapTask* task, uint64_t new_target_time) {
101 bool TaskProcessor::IsRunning() const {
106 Thread* TaskProcessor::GetRunningThread() const {
111 void TaskProcessor::Stop(Thread* self) {
118 void TaskProcessor::Start(Thread* self) {
124 void TaskProcessor::RunAllTasks(Thread* self) {
