/art/runtime/ |
H A D | thread_pool_test.cc | 22 #include "thread_pool.h" 62 ThreadPool thread_pool(num_threads); 66 thread_pool.AddTask(self, new CountTask(&count)); 68 thread_pool.StartWorkers(self); 70 thread_pool.Wait(self, true, false); 77 ThreadPool thread_pool(num_threads); 81 thread_pool.AddTask(self, new CountTask(&count)); 87 thread_pool.StartWorkers(self); 89 thread_pool.StopWorkers(self); 91 thread_pool 105 TreeTask(ThreadPool* const thread_pool, AtomicInteger* count, int depth) argument [all...] |
H A D | barrier_test.cc | 24 #include "thread_pool.h" 69 ThreadPool thread_pool(num_threads); 75 thread_pool.AddTask(self, new CheckWaitTask(&barrier, &count1, &count2, &count3)); 77 thread_pool.StartWorkers(self); 90 thread_pool.Wait(self, true, false); 124 ThreadPool thread_pool(num_threads); 130 thread_pool.AddTask(self, new CheckPassTask(&barrier, &count, num_sub_tasks)); 132 thread_pool.StartWorkers(self);
|
H A D | thread_pool.cc | 17 #include "thread_pool.h" 28 ThreadPoolWorker::ThreadPoolWorker(ThreadPool* thread_pool, const std::string& name, argument 30 : thread_pool_(thread_pool), 198 WorkStealingWorker::WorkStealingWorker(ThreadPool* thread_pool, const std::string& name, argument 200 : ThreadPoolWorker(thread_pool, name, stack_size), task_(NULL) {} 205 WorkStealingThreadPool* thread_pool = down_cast<WorkStealingThreadPool*>(thread_pool_); local 211 MutexLock mu(self, thread_pool->work_steal_lock_); 227 while (thread_pool->GetTaskCount(self) == 0) { 231 MutexLock mu(self, thread_pool->work_steal_lock_); 233 steal_from_task = thread_pool [all...] |
H A D | thread_pool.h | 49 ThreadPoolWorker(ThreadPool* thread_pool, const std::string& name, size_t stack_size); 160 WorkStealingWorker(ThreadPool* thread_pool, const std::string& name, size_t stack_size);
|
H A D | Android.mk | 124 thread_pool.cc \
|
/art/compiler/driver/ |
H A D | compiler_driver.h | 36 #include "thread_pool.h" 331 ThreadPool& thread_pool, base::TimingLogger& timings) 340 ThreadPool& thread_pool, base::TimingLogger& timings) 343 ThreadPool& thread_pool, base::TimingLogger& timings) 347 ThreadPool& thread_pool, base::TimingLogger& timings); 349 ThreadPool& thread_pool, base::TimingLogger& timings) 353 ThreadPool& thread_pool, base::TimingLogger& timings) 356 ThreadPool& thread_pool, base::TimingLogger& timings) 364 ThreadPool& thread_pool, base::TimingLogger& timings); 366 ThreadPool& thread_pool, bas [all...] |
H A D | compiler_driver.cc | 47 #include "thread_pool.h" 492 UniquePtr<ThreadPool> thread_pool(new ThreadPool(thread_count_ - 1)); 493 PreCompile(class_loader, dex_files, *thread_pool.get(), timings); 494 Compile(class_loader, dex_files, *thread_pool.get(), timings); 556 UniquePtr<ThreadPool> thread_pool(new ThreadPool(0U)); 557 PreCompile(jclass_loader, dex_files, *thread_pool.get(), timings); 578 ThreadPool& thread_pool, base::TimingLogger& timings) { 582 ResolveDexFile(class_loader, *dex_file, thread_pool, timings); 587 ThreadPool& thread_pool, base::TimingLogger& timings) { 590 Resolve(class_loader, dex_files, thread_pool, timing 577 Resolve(jobject class_loader, const std::vector<const DexFile*>& dex_files, ThreadPool& thread_pool, base::TimingLogger& timings) argument 586 PreCompile(jobject class_loader, const std::vector<const DexFile*>& dex_files, ThreadPool& thread_pool, base::TimingLogger& timings) argument 1340 ParallelCompilationManager(ClassLinker* class_linker, jobject class_loader, CompilerDriver* compiler, const DexFile* dex_file, ThreadPool& thread_pool) argument 1581 ResolveDexFile(jobject class_loader, const DexFile& dex_file, ThreadPool& thread_pool, base::TimingLogger& timings) argument 1602 Verify(jobject class_loader, const std::vector<const DexFile*>& dex_files, ThreadPool& thread_pool, base::TimingLogger& timings) argument 1659 VerifyDexFile(jobject class_loader, const DexFile& dex_file, ThreadPool& thread_pool, base::TimingLogger& timings) argument 2158 InitializeClasses(jobject jni_class_loader, const DexFile& dex_file, ThreadPool& thread_pool, base::TimingLogger& timings) argument 2176 InitializeClasses(jobject class_loader, const std::vector<const DexFile*>& dex_files, ThreadPool& thread_pool, base::TimingLogger& timings) argument 2186 Compile(jobject class_loader, const std::vector<const DexFile*>& dex_files, ThreadPool& thread_pool, base::TimingLogger& timings) argument 2266 CompileDexFile(jobject class_loader, const DexFile& dex_file, ThreadPool& thread_pool, base::TimingLogger& timings) argument [all...] |
/art/runtime/gc/collector/ |
H A D | mark_sweep.cc | 632 MarkStackTask(ThreadPool* thread_pool, MarkSweep* mark_sweep, size_t mark_stack_size, argument 635 thread_pool_(thread_pool), 744 CardScanTask(ThreadPool* thread_pool, MarkSweep* mark_sweep, accounting::SpaceBitmap* bitmap, 747 : MarkStackTask<false>(thread_pool, mark_sweep, mark_stack_size, mark_stack_obj), 789 ThreadPool* thread_pool = GetHeap()->GetThreadPool(); local 828 auto* task = new CardScanTask(thread_pool, this, space->GetMarkBitmap(), card_begin, 831 thread_pool->AddTask(self, task); 845 thread_pool->SetMaxActiveWorkers(thread_count - 1); 846 thread_pool->StartWorkers(self); 847 thread_pool 903 RecursiveMarkTask(ThreadPool* thread_pool, MarkSweep* mark_sweep, accounting::SpaceBitmap* bitmap, uintptr_t begin, uintptr_t end) argument 945 ThreadPool* thread_pool = heap_->GetThreadPool(); local 1404 ThreadPool* thread_pool = GetHeap()->GetThreadPool(); local [all...] |