| /art/runtime/ |
| D | thread_pool_test.cc | 63 ThreadPool thread_pool("Thread pool test thread pool", num_threads); in TEST_F() local
67 thread_pool.AddTask(self, new CountTask(&count)); in TEST_F()
69 thread_pool.StartWorkers(self); in TEST_F()
71 thread_pool.Wait(self, true, false); in TEST_F()
78 ThreadPool thread_pool("Thread pool test thread pool", num_threads); in TEST_F() local
82 thread_pool.AddTask(self, new CountTask(&count)); in TEST_F()
88 thread_pool.StartWorkers(self); in TEST_F()
90 thread_pool.StopWorkers(self); in TEST_F()
92 thread_pool.AddTask(self, new CountTask(&bad_count)); in TEST_F()
97 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 | thread_pool.cc | 29 ThreadPoolWorker::ThreadPoolWorker(ThreadPool* thread_pool, const std::string& name, in ThreadPoolWorker() argument
31 : thread_pool_(thread_pool), in ThreadPoolWorker()
204 WorkStealingWorker::WorkStealingWorker(ThreadPool* thread_pool, const std::string& name, in WorkStealingWorker() argument
206 : ThreadPoolWorker(thread_pool, name, stack_size), task_(nullptr) {} in WorkStealingWorker()
211 WorkStealingThreadPool* thread_pool = down_cast<WorkStealingThreadPool*>(thread_pool_); in Run() local
217 MutexLock mu(self, thread_pool->work_steal_lock_); in Run()
233 while (thread_pool->GetTaskCount(self) == 0) { in Run()
237 MutexLock mu(self, thread_pool->work_steal_lock_); in Run()
239 steal_from_task = thread_pool->FindTaskToStealFrom(); in Run()
255 MutexLock mu(self, thread_pool->work_steal_lock_); in Run()
[all …]
|
| D | monitor_test.cc | 329 ThreadPool thread_pool(pool_name, 3); in CommonWaitSetup() local
330 thread_pool.AddTask(self, new CreateTask(test, create_sleep, c_millis, c_expected)); in CommonWaitSetup()
332 thread_pool.AddTask(self, new InterruptTask(test, use_sleep, static_cast<uint64_t>(u_millis))); in CommonWaitSetup()
334 thread_pool.AddTask(self, new UseTask(test, use_sleep, u_millis, u_expected)); in CommonWaitSetup()
336 thread_pool.AddTask(self, new WatchdogTask(test)); in CommonWaitSetup()
337 thread_pool.StartWorkers(self); in CommonWaitSetup()
352 thread_pool.StopWorkers(self); in CommonWaitSetup()
|
| D | thread_pool.h | 63 ThreadPoolWorker(ThreadPool* thread_pool, const std::string& name, size_t stack_size);
175 WorkStealingWorker(ThreadPool* thread_pool, const std::string& name, size_t stack_size);
|
| D | oat_file_assistant_test.cc | 963 ThreadPool thread_pool("Oat file assistant test thread pool", kNumThreads); in TEST_F() local
967 thread_pool.AddTask(self, task.get()); in TEST_F()
970 thread_pool.StartWorkers(self); in TEST_F()
971 thread_pool.Wait(self, true, false); in TEST_F()
|
| D | Android.mk | 164 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()
137 ThreadPool thread_pool("task processor test", 1U); in TEST_F() local
140 thread_pool.AddTask(self, new WorkUntilDoneTask(&task_processor, &done_running)); in TEST_F()
142 thread_pool.StartWorkers(self); in TEST_F()
[all …]
|
| /art/runtime/gc/collector/ |
| D | mark_sweep.cc | 633 MarkStackTask(ThreadPool* thread_pool, MarkSweep* mark_sweep, size_t mark_stack_size, in MarkStackTask() argument
636 thread_pool_(thread_pool), in MarkStackTask()
764 CardScanTask(ThreadPool* thread_pool, MarkSweep* mark_sweep, in CardScanTask() argument
768 : MarkStackTask<false>(thread_pool, mark_sweep, mark_stack_size, mark_stack_obj), in CardScanTask()
808 ThreadPool* thread_pool = GetHeap()->GetThreadPool(); in ScanGrayObjects() local
859 auto* task = new CardScanTask(thread_pool, this, space->GetMarkBitmap(), card_begin, in ScanGrayObjects()
862 thread_pool->AddTask(self, task); in ScanGrayObjects()
870 thread_pool->SetMaxActiveWorkers(thread_count - 1); in ScanGrayObjects()
871 thread_pool->StartWorkers(self); in ScanGrayObjects()
872 thread_pool->Wait(self, true, true); in ScanGrayObjects()
[all …]
|
| /art/runtime/gc/space/ |
| D | large_object_space_test.cc | 154 ThreadPool thread_pool("Large object space test thread pool", kNumThreads); in RaceTest() local
156 thread_pool.AddTask(self, new AllocRaceTask(i, kNumIterations, 16 * KB, los)); in RaceTest()
159 thread_pool.StartWorkers(self); in RaceTest()
161 thread_pool.Wait(self, true, false); in RaceTest()
|
| /art/compiler/driver/ |
| D | compiler_driver.h | 551 ThreadPool* thread_pool, TimingLogger* timings)
560 ThreadPool* thread_pool, TimingLogger* timings)
564 ThreadPool* thread_pool, TimingLogger* timings)
568 ThreadPool* thread_pool, TimingLogger* timings);
571 ThreadPool* thread_pool, TimingLogger* timings)
575 ThreadPool* thread_pool, TimingLogger* timings);
578 ThreadPool* thread_pool, TimingLogger* timings)
582 ThreadPool* thread_pool, TimingLogger* timings)
586 ThreadPool* thread_pool, TimingLogger* timings)
594 ThreadPool* thread_pool, TimingLogger* timings);
[all …]
|
| D | compiler_driver.cc | 501 std::unique_ptr<ThreadPool> thread_pool( in CompileAll() local
504 PreCompile(class_loader, dex_files, thread_pool.get(), timings); in CompileAll()
505 Compile(class_loader, dex_files, thread_pool.get(), timings); in CompileAll()
569 std::unique_ptr<ThreadPool> thread_pool(new ThreadPool("Compiler driver thread pool", 0U)); in CompileOne() local
570 PreCompile(jclass_loader, dex_files, thread_pool.get(), timings); in CompileOne()
613 ThreadPool* thread_pool, TimingLogger* timings) { in Resolve() argument
617 ResolveDexFile(class_loader, *dex_file, dex_files, thread_pool, timings); in Resolve()
622 ThreadPool* thread_pool, TimingLogger* timings) { in PreCompile() argument
632 Resolve(class_loader, dex_files, thread_pool, timings); in PreCompile()
638 SetVerified(class_loader, dex_files, thread_pool, timings); in PreCompile()
[all …]
|