Searched refs:task (Results 1 - 8 of 8) sorted by relevance

/art/runtime/gc/
H A Dtask_processor.cc36 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 Dtask_processor.h39 // Update the updated_target_run_time_, the task processor will re-insert the task when it is
45 // Time in ns at which we want the task to run.
57 void AddTask(Thread* self, HeapTask* task) REQUIRES(!*lock_);
H A Dtask_processor_test.cc66 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.
H A Dreference_processor.cc255 ClearedReferenceTask task(cleared_references);
256 task.Run(self);
/art/runtime/
H A Dthread_pool.cc76 Task* task = nullptr; local
78 while ((task = thread_pool_->GetTask(self)) != nullptr) {
79 task->Run(self);
80 task->Finalize();
94 void ThreadPool::AddTask(Thread* self, Task* task) { argument
96 tasks_.push_back(task);
110 task_queue_lock_("task queue lock"),
111 task_queue_condition_("task queue condition", task_queue_lock_),
112 completion_condition_("task completion condition", task_queue_lock_),
173 Task* task local
204 Task* task = tasks_.front(); local
213 Task* task = nullptr; local
[all...]
H A Dthread_pool.h93 // Add a new task, the first available started worker will process it. Does not delete the task
95 void AddTask(Thread* self, Task* task) REQUIRES(!task_queue_lock_);
121 // get a task to run, blocks if there are no tasks left
124 // Try to get a task, returning null if there is none available.
H A Doat_file_assistant_test.cc1255 // A task to generate a dex location. Used by the RaceToGenerate test.
1310 std::unique_ptr<RaceGenerateTask> task(new RaceGenerateTask(dex_location, oat_location));
1311 thread_pool.AddTask(self, task.get());
1312 tasks.push_back(std::move(task));
1317 // Verify every task got a unique oat file.
1319 for (auto& task : tasks) {
1320 const OatFile* oat_file = task->GetLoadedOatFile();
/art/runtime/gc/collector/
H A Dmark_sweep.cc746 // Thread local mark stack for this task.
754 // Mark stack overflow, give 1/2 the stack to the thread pool as a new work task.
756 auto* task = new MarkStackTask(thread_pool_, local
760 thread_pool_->AddTask(Thread::Current(), task); local
889 // Calculate how much address range each task gets.
908 // Add the new task to the thread pool.
909 auto* task = new CardScanTask(thread_pool, local
918 thread_pool->AddTask(self, task);
1037 auto* task = new RecursiveMarkTask(thread_pool, local
1042 thread_pool->AddTask(self, task);
[all...]

Completed in 96 milliseconds