Searched defs:task (Results 1 - 4 of 4) sorted by relevance
/art/runtime/gc/ |
H A D | task_processor.cc | 36 void TaskProcessor::AddTask(Thread* self, HeapTask* task) { argument 39 tasks_.insert(task); 55 HeapTask* task = *tasks_.begin(); local 56 // If we are shutting down, return the task right away without waiting. Otherwise return the 57 // task if it is late enough. 58 uint64_t target_time = task->GetTargetRunTime(); 61 return task; 74 void TaskProcessor::UpdateTargetRunTime(Thread* self, HeapTask* task, uint64_t new_target_time) { argument 76 // Find the task. 77 auto range = tasks_.equal_range(task); 122 HeapTask* task = GetTask(self); local [all...] |
H A D | task_processor_test.cc | 66 ThreadPool thread_pool("task processor test", 1U); 74 // Add a task which will wait until interrupted to the thread pool. 133 auto* task = new TestOrderTask(pair.first, pair.second, &counter); local 134 task_processor.AddTask(self, task); 136 ThreadPool thread_pool("task processor test", 1U); 138 // Add a task which will wait until interrupted to the thread pool.
|
/art/runtime/ |
H A D | thread_pool.cc | 80 Task* task = nullptr; local 82 while ((task = thread_pool_->GetTask(self)) != nullptr) { 83 task->Run(self); 84 task->Finalize(); 104 void ThreadPool::AddTask(Thread* self, Task* task) { argument 106 tasks_.push_back(task); 120 task_queue_lock_("task queue lock"), 121 task_queue_condition_("task queue condition", task_queue_lock_), 122 completion_condition_("task completion condition", task_queue_lock_), 184 Task* task local 215 Task* task = tasks_.front(); local 225 Task* task = nullptr; local [all...] |
/art/runtime/gc/collector/ |
H A D | mark_sweep.cc | 745 // Thread local mark stack for this task. 753 // Mark stack overflow, give 1/2 the stack to the thread pool as a new work task. 755 auto* task = new MarkStackTask(thread_pool_, local 759 thread_pool_->AddTask(Thread::Current(), task); local 888 // Calculate how much address range each task gets. 907 // Add the new task to the thread pool. 908 auto* task = new CardScanTask(thread_pool, local 917 thread_pool->AddTask(self, task); 1036 auto* task = new RecursiveMarkTask(thread_pool, local 1041 thread_pool->AddTask(self, task); [all...] |
Completed in 463 milliseconds