| /art/runtime/ |
| D | thread_pool_test.cc | 64 std::unique_ptr<ThreadPool> thread_pool( in TEST_F() local
69 thread_pool->AddTask(self, new CountTask(&count)); in TEST_F()
71 thread_pool->StartWorkers(self); in TEST_F()
73 thread_pool->Wait(self, true, false); in TEST_F()
80 std::unique_ptr<ThreadPool> thread_pool( in TEST_F() local
85 thread_pool->AddTask(self, new CountTask(&count)); in TEST_F()
91 thread_pool->StartWorkers(self); in TEST_F()
93 thread_pool->StopWorkers(self); in TEST_F()
95 thread_pool->AddTask(self, new CountTask(&bad_count)); in TEST_F()
100 thread_pool->StartWorkers(self); in TEST_F()
[all …]
|
| D | barrier_test.cc | 67 std::unique_ptr<ThreadPool> thread_pool( in TEST_F() local
74 thread_pool->AddTask(self, new CheckWaitTask(&barrier, &count1, &count2)); in TEST_F()
76 thread_pool->StartWorkers(self); in TEST_F()
85 thread_pool->Wait(self, true, false); in TEST_F()
119 std::unique_ptr<ThreadPool> thread_pool( in TEST_F() local
126 thread_pool->AddTask(self, new CheckPassTask(&barrier, &count, num_sub_tasks)); in TEST_F()
128 thread_pool->StartWorkers(self); in TEST_F()
|
| D | monitor_test.cc | 281 std::unique_ptr<ThreadPool> thread_pool(ThreadPool::Create(pool_name, 3)); in CommonWaitSetup() local
282 thread_pool->AddTask(self, new CreateTask(test, create_sleep, c_millis, c_expected)); in CommonWaitSetup()
284 thread_pool->AddTask(self, new InterruptTask(test, use_sleep, static_cast<uint64_t>(u_millis))); in CommonWaitSetup()
286 thread_pool->AddTask(self, new UseTask(test, use_sleep, u_millis, u_expected)); in CommonWaitSetup()
288 thread_pool->AddTask(self, new WatchdogTask(test)); in CommonWaitSetup()
289 thread_pool->StartWorkers(self); in CommonWaitSetup()
303 thread_pool->StopWorkers(self); in CommonWaitSetup()
364 std::unique_ptr<ThreadPool> thread_pool(ThreadPool::Create("the pool", 2)); in TEST_F() local
378 thread_pool->AddTask(self, new TryLockTask(g_obj1)); in TEST_F()
379 thread_pool->StartWorkers(self); in TEST_F()
[all …]
|
| D | thread_pool.cc | 49 ThreadPoolWorker::ThreadPoolWorker(AbstractThreadPool* thread_pool, in ThreadPoolWorker() argument
52 : thread_pool_(thread_pool), in ThreadPoolWorker()
|
| D | thread_pool.h | 96 ThreadPoolWorker(AbstractThreadPool* thread_pool, const std::string& name, size_t stack_size);
|
| D | runtime.cc | 3267 std::unique_ptr<ThreadPool> thread_pool; in DeleteThreadPool() local
3271 thread_pool = std::move(thread_pool_); in DeleteThreadPool()
3274 return thread_pool != nullptr; in DeleteThreadPool()
|
| D | Android.bp | 418 "thread_pool.cc",
|
| /art/runtime/gc/ |
| D | task_processor_test.cc | 66 std::unique_ptr<ThreadPool> thread_pool(ThreadPool::Create("task processor test", 1U)); in TEST_F() local
75 thread_pool->AddTask(self, new WorkUntilDoneTask(&task_processor, &done_running)); in TEST_F()
76 thread_pool->StartWorkers(self); in TEST_F()
84 thread_pool->Wait(self, true, false); in TEST_F()
96 thread_pool->AddTask(self, new WorkUntilDoneTask(&task_processor, &done_running)); in TEST_F()
97 thread_pool->StartWorkers(self); in TEST_F()
98 thread_pool->Wait(self, true, false); in TEST_F()
136 std::unique_ptr<ThreadPool> thread_pool(ThreadPool::Create("task processor test", 1U)); in TEST_F() local
139 thread_pool->AddTask(self, new WorkUntilDoneTask(&task_processor, &done_running)); in TEST_F()
141 thread_pool->StartWorkers(self); in TEST_F()
[all …]
|
| /art/runtime/gc/collector/ |
| D | mark_sweep.cc | 674 MarkStackTask(ThreadPool* thread_pool, in MarkStackTask() argument
679 thread_pool_(thread_pool), in MarkStackTask()
831 CardScanTask(ThreadPool* thread_pool, in CardScanTask() argument
840 : MarkStackTask<false>(thread_pool, mark_sweep, mark_stack_size, mark_stack_obj), in CardScanTask()
882 ThreadPool* thread_pool = GetHeap()->GetThreadPool(); in ScanGrayObjects() local
933 auto* task = new CardScanTask(thread_pool, in ScanGrayObjects()
942 thread_pool->AddTask(self, task); in ScanGrayObjects()
950 thread_pool->SetMaxActiveWorkers(thread_count - 1); in ScanGrayObjects()
951 thread_pool->StartWorkers(self); in ScanGrayObjects()
952 thread_pool->Wait(self, true, true); in ScanGrayObjects()
[all …]
|
| /art/runtime/gc/space/ |
| D | large_object_space_test.cc | 164 std::unique_ptr<ThreadPool> thread_pool( in RaceTest() local
167 thread_pool->AddTask(self, new AllocRaceTask(i, kNumIterations, 16 * KB, los)); in RaceTest()
170 thread_pool->StartWorkers(self); in RaceTest()
172 thread_pool->Wait(self, true, false); in RaceTest()
|
| /art/tools/jvmti-agents/jit-load/ |
| D | jitload.cc | 44 auto* thread_pool = jit->GetThreadPool(); in GetJitThread() local
45 if (thread_pool == nullptr) { in GetJitThread()
50 thread_pool->GetWorkers()[0]->GetThread()->GetPeerFromOtherThread()); in GetJitThread()
|
| /art/dex2oat/driver/ |
| D | compiler_driver.h | 239 ThreadPool* thread_pool,
256 ThreadPool* thread_pool,
266 ThreadPool* thread_pool,
|
| D | compiler_driver.cc | 1551 ThreadPool* thread_pool) in ParallelCompilationManager() argument
1557 thread_pool_(thread_pool) {} in ParallelCompilationManager()
1773 ThreadPool* thread_pool, in ResolveDexFile() argument
1783 ParallelCompilationManager context(class_linker, class_loader, this, &dex_file, thread_pool); in ResolveDexFile()
2117 ThreadPool* thread_pool, in VerifyDexFile() argument
2122 ParallelCompilationManager context(class_linker, class_loader, this, &dex_file, thread_pool); in VerifyDexFile()
2184 ThreadPool* thread_pool, in SetVerifiedDexFile() argument
2192 ParallelCompilationManager context(class_linker, class_loader, this, &dex_file, thread_pool); in SetVerifiedDexFile()
2667 ThreadPool* thread_pool, in CompileDexFile() argument
2677 thread_pool); in CompileDexFile()
|
| /art/runtime/jit/ |
| D | jit.cc | 683 JitThreadPool* thread_pool = Runtime::Current()->GetJit()->GetThreadPool(); in Finalize() local
684 if (thread_pool != nullptr) { in Finalize()
685 thread_pool->Remove(this); in Finalize()
|
| /art/runtime/oat/ |
| D | oat_file_assistant_test.cc | 1610 std::unique_ptr<ThreadPool> thread_pool( in TEST_F() local
1617 thread_pool->AddTask(self, task.get()); in TEST_F()
1620 thread_pool->StartWorkers(self); in TEST_F()
1621 thread_pool->Wait(self, /* do_work= */ true, /* may_hold_locks= */ false); in TEST_F()
|