| /art/runtime/ |
| D | thread_pool_test.cc | 64 ThreadPool thread_pool("Thread pool test thread pool", num_threads); in TEST_F() local
68 thread_pool.AddTask(self, new CountTask(&count)); in TEST_F()
70 thread_pool.StartWorkers(self); in TEST_F()
72 thread_pool.Wait(self, true, false); in TEST_F()
79 ThreadPool thread_pool("Thread pool test thread pool", num_threads); in TEST_F() local
83 thread_pool.AddTask(self, new CountTask(&count)); in TEST_F()
89 thread_pool.StartWorkers(self); in TEST_F()
91 thread_pool.StopWorkers(self); in TEST_F()
93 thread_pool.AddTask(self, new CountTask(&bad_count)); in TEST_F()
98 thread_pool.StartWorkers(self); in TEST_F()
[all …]
|
| D | barrier_test.cc | 63 ThreadPool thread_pool("Barrier test thread pool", num_threads); in TEST_F() local
69 thread_pool.AddTask(self, new CheckWaitTask(&barrier, &count1, &count2)); in TEST_F()
71 thread_pool.StartWorkers(self); in TEST_F()
80 thread_pool.Wait(self, true, false); in TEST_F()
114 ThreadPool thread_pool("Barrier test thread pool", num_threads); in TEST_F() local
120 thread_pool.AddTask(self, new CheckPassTask(&barrier, &count, num_sub_tasks)); in TEST_F()
122 thread_pool.StartWorkers(self); in TEST_F()
|
| D | monitor_test.cc | 321 ThreadPool thread_pool(pool_name, 3); in CommonWaitSetup() local
322 thread_pool.AddTask(self, new CreateTask(test, create_sleep, c_millis, c_expected)); in CommonWaitSetup()
324 thread_pool.AddTask(self, new InterruptTask(test, use_sleep, static_cast<uint64_t>(u_millis))); in CommonWaitSetup()
326 thread_pool.AddTask(self, new UseTask(test, use_sleep, u_millis, u_expected)); in CommonWaitSetup()
328 thread_pool.AddTask(self, new WatchdogTask(test)); in CommonWaitSetup()
329 thread_pool.StartWorkers(self); in CommonWaitSetup()
343 thread_pool.StopWorkers(self); in CommonWaitSetup()
402 ThreadPool thread_pool("the pool", 2); in TEST_F() local
414 thread_pool.AddTask(self, new TryLockTask(obj1)); in TEST_F()
415 thread_pool.StartWorkers(self); in TEST_F()
[all …]
|
| D | thread_pool.cc | 40 ThreadPoolWorker::ThreadPoolWorker(ThreadPool* thread_pool, const std::string& name, in ThreadPoolWorker() argument
42 : thread_pool_(thread_pool), in ThreadPoolWorker()
|
| D | thread_pool.h | 68 ThreadPoolWorker(ThreadPool* thread_pool, const std::string& name, size_t stack_size);
|
| D | oat_file_assistant_test.cc | 1098 ThreadPool thread_pool("Oat file assistant test thread pool", kNumThreads); in TEST_F() local
1102 thread_pool.AddTask(self, task.get()); in TEST_F()
1105 thread_pool.StartWorkers(self); in TEST_F()
1106 thread_pool.Wait(self, true, false); in TEST_F()
|
| D | Android.bp | 203 "thread_pool.cc",
|
| /art/runtime/gc/ |
| D | task_processor_test.cc | 66 ThreadPool thread_pool("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 ThreadPool thread_pool("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 | 648 MarkStackTask(ThreadPool* thread_pool, in MarkStackTask() argument
653 thread_pool_(thread_pool), in MarkStackTask()
806 CardScanTask(ThreadPool* thread_pool, in CardScanTask() argument
815 : MarkStackTask<false>(thread_pool, mark_sweep, mark_stack_size, mark_stack_obj), in CardScanTask()
857 ThreadPool* thread_pool = GetHeap()->GetThreadPool(); in ScanGrayObjects() local
908 auto* task = new CardScanTask(thread_pool, in ScanGrayObjects()
917 thread_pool->AddTask(self, task); in ScanGrayObjects()
925 thread_pool->SetMaxActiveWorkers(thread_count - 1); in ScanGrayObjects()
926 thread_pool->StartWorkers(self); in ScanGrayObjects()
927 thread_pool->Wait(self, true, true); in ScanGrayObjects()
[all …]
|
| /art/runtime/gc/space/ |
| D | large_object_space_test.cc | 156 ThreadPool thread_pool("Large object space test thread pool", kNumThreads); in RaceTest() local
158 thread_pool.AddTask(self, new AllocRaceTask(i, kNumIterations, 16 * KB, los)); in RaceTest()
161 thread_pool.StartWorkers(self); in RaceTest()
163 thread_pool.Wait(self, true, false); in RaceTest()
|
| /art/compiler/driver/ |
| D | compiler_driver.h | 391 ThreadPool* thread_pool,
412 ThreadPool* thread_pool,
423 ThreadPool* thread_pool,
446 ThreadPool* thread_pool,
|
| D | compiler_driver.cc | 1535 ThreadPool* thread_pool) in ParallelCompilationManager() argument
1542 thread_pool_(thread_pool) {} in ParallelCompilationManager()
1852 ThreadPool* thread_pool, in ResolveDexFile() argument
1861 thread_pool); in ResolveDexFile()
2169 ThreadPool* thread_pool, in VerifyDexFile() argument
2175 thread_pool); in VerifyDexFile()
2233 ThreadPool* thread_pool, in SetVerifiedDexFile() argument
2239 thread_pool); in SetVerifiedDexFile()
2669 ThreadPool* thread_pool, in CompileDexFile() argument
2674 &dex_file, dex_files, thread_pool); in CompileDexFile()
|