| /art/runtime/gc/ |
| D | task_processor.cc | 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()
[all …]
|
| D | task_processor_test.cc | 133 auto* task = new TestOrderTask(pair.first, pair.second, &counter); in TEST_F() local
134 task_processor.AddTask(self, task); in TEST_F()
|
| D | task_processor.h | 58 void AddTask(Thread* self, HeapTask* task) REQUIRES(!lock_);
|
| D | heap.h | 1008 bool AddHeapTask(gc::HeapTask* task);
|
| D | heap.cc | 4804 bool Heap::AddHeapTask(gc::HeapTask* task) { in AddHeapTask() argument
4809 GetTaskProcessor()->AddTask(self, task); in AddHeapTask()
|
| /art/libartservice/service/javatests/com/android/server/art/testing/ |
| D | MockClock.java | 72 var task = (RunnableScheduledFuture<?>) super.schedule( in schedule() local
74 tasks.add(Pair.create(task, getCurrentTimeMs() + unit.toMillis(delay))); in schedule()
75 return task; in schedule()
81 RunnableScheduledFuture<?> task = pair.first; in notifyUpdate() local
83 if (getCurrentTimeMs() >= scheduledTimeMs || task.isCancelled()) { in notifyUpdate()
84 if (!task.isDone() && !task.isCancelled()) { in notifyUpdate()
85 task.run(); in notifyUpdate()
90 super.remove(task); in notifyUpdate()
|
| /art/runtime/ |
| D | thread_pool.cc | 120 Task* task = nullptr; in Run() local
122 while ((task = thread_pool_->GetTask(self)) != nullptr) { in Run()
123 task->Run(self); in Run()
124 task->Finalize(); in Run()
162 void ThreadPool::AddTask(Thread* self, Task* task) { in AddTask() argument
164 tasks_.push_back(task); in AddTask()
174 Task* task = nullptr; in RemoveAllTasks() local
181 task = tasks_.front(); in RemoveAllTasks()
184 task->Finalize(); in RemoveAllTasks()
286 Task* task = TryGetTaskLocked(); in GetTask() local
[all …]
|
| D | thread_pool.h | 132 virtual void AddTask(Thread* self, Task* task) REQUIRES(!task_queue_lock_) = 0;
230 void AddTask(Thread* self, Task* task) REQUIRES(!task_queue_lock_) override;
|
| D | mutator_gc_coord.md | 148 its task. Deadlocks are avoided as follows:
|
| /art/runtime/jit/ |
| D | jit.cc | 1257 Task* task = new JitCompileTask( in CompileMethodFromProfile() local
1260 AddPostBootTask(self, task); in CompileMethodFromProfile()
1262 thread_pool_->AddTask(self, task); in CompileMethodFromProfile()
1620 void Jit::AddPostBootTask(Thread* self, Task* task) { in AddPostBootTask() argument
1623 thread_pool_->AddTask(self, task); in AddPostBootTask()
1625 tasks_after_boot_.push_back(task); in AddPostBootTask()
1637 for (Task* task : tasks) { in BootCompleted()
1638 thread_pool_->AddTask(self, task); in BootCompleted()
1754 Task* task = nullptr; in RemoveAllTasks() local
1761 task = generic_queue_.front(); in RemoveAllTasks()
[all …]
|
| D | jit.h | 126 void AddTask(Thread* self, Task* task) REQUIRES(!task_queue_lock_) override;
132 void Remove(JitCompileTask* task) REQUIRES(!task_queue_lock_);
337 void AddPostBootTask(Thread* self, Task* task);
|
| /art/test/708-jit-cache-churn/src/ |
| D | JitCacheChurnTest.java | 71 private void runTasks(Callable<Integer> task) { in runTasks() argument
73 ensureJitCompiled(task.getClass(), JITTED_METHOD); in runTasks()
79 tasks.add(i, task); in runTasks()
|
| /art/runtime/gc/collector/ |
| D | mark_sweep.cc | 781 auto* task = new MarkStackTask(thread_pool_, in MarkStackPush() local
785 thread_pool_->AddTask(Thread::Current(), task); in MarkStackPush()
933 auto* task = new CardScanTask(thread_pool, in ScanGrayObjects() local
942 thread_pool->AddTask(self, task); in ScanGrayObjects()
1058 auto* task = new RecursiveMarkTask(thread_pool, in RecursiveMark() local
1063 thread_pool->AddTask(self, task); in RecursiveMark()
|
| /art/runtime/oat/ |
| D | oat_file_assistant_test.cc | 1615 std::unique_ptr<RaceGenerateTask> task( in TEST_F() local
1617 thread_pool->AddTask(self, task.get()); in TEST_F()
1618 tasks.push_back(std::move(task)); in TEST_F()
1625 for (auto& task : tasks) { in TEST_F() local
1626 const OatFile* oat_file = task->GetLoadedOatFile(); in TEST_F()
|
| /art/build/boot/hiddenapi/ |
| D | hiddenapi-max-target-o-low-priority.txt | 7414 Ljava/util/concurrent/ExecutorCompletionService$QueueingFuture;->task:Ljava/util/concurrent/Future;
7432 Ljava/util/concurrent/Executors$PrivilegedCallable;->task:Ljava/util/concurrent/Callable;
7436 Ljava/util/concurrent/Executors$PrivilegedCallableUsingCurrentClassLoader;->task:Ljava/util/concurr…
|