Searched refs:thread_pool_ (Results 1 – 11 of 11) sorted by relevance
| /art/runtime/jit/ |
| D | jit.cc | 299 if (thread_pool_ != nullptr) { in WaitForWorkersToBeCreated()
300 thread_pool_->WaitForWorkersToBeCreated(); in WaitForWorkersToBeCreated()
307 if (thread_pool_ != nullptr) { in DeleteThreadPool()
313 pool = std::move(thread_pool_); in DeleteThreadPool()
702 thread_pool_.reset(new ThreadPool("Jit thread pool", 1, kJitPoolNeedsPeers)); in CreateThreadPool()
704 thread_pool_->SetPthreadPriority(options_->GetThreadPoolPthreadPriority()); in CreateThreadPool()
711 thread_pool_->AddTask(Thread::Current(), new ZygoteTask()); in CreateThreadPool()
722 thread_pool_->AddTask(Thread::Current(), new JitProfileTask(dex_files, class_loader)); in RegisterDexFiles()
810 thread_pool_->AddTask(self, in CompileMethodsFromProfile()
844 if (thread_pool_ == nullptr) { in MaybeCompileMethod()
[all …]
|
| D | jit.h | 292 return thread_pool_.get(); in GetThreadPool()
353 std::unique_ptr<ThreadPool> thread_pool_; variable
|
| /art/runtime/ |
| D | thread_pool_test.cc | 128 : thread_pool_(thread_pool), in TreeTask()
134 thread_pool_->AddTask(self, new TreeTask(thread_pool_, count_, depth_ - 1)); in Run()
135 thread_pool_->AddTask(self, new TreeTask(thread_pool_, count_, depth_ - 1)); in Run()
146 ThreadPool* const thread_pool_; member in art::TreeTask
|
| D | thread_pool.cc | 45 : thread_pool_(thread_pool), in ThreadPoolWorker()
90 thread_pool_->creation_barier_.Pass(self); in Run()
91 while ((task = thread_pool_->GetTask(self)) != nullptr) { in Run()
103 worker->thread_pool_->create_peers_)); in Callback()
|
| D | thread_pool.h | 96 ThreadPool* const thread_pool_; variable
|
| D | runtime.h | 853 return thread_pool_; in GetThreadPool()
857 ThreadPool* const thread_pool_;
1007 std::unique_ptr<ThreadPool> thread_pool_ GUARDED_BY(Locks::runtime_thread_pool_lock_);
|
| D | runtime.cc | 431 CHECK(thread_pool_ == nullptr); in ~Runtime()
995 CHECK(thread_pool_ == nullptr); in InitNonZygoteOrPostFork()
996 thread_pool_.reset(new ThreadPool("Runtime", num_workers, /*create_peers=*/false, kStackSize)); in InitNonZygoteOrPostFork()
997 thread_pool_->StartWorkers(Thread::Current()); in InitNonZygoteOrPostFork()
2781 : thread_pool_(Runtime::Current()->AcquireThreadPool()) {} in ScopedThreadPoolUsage()
2794 thread_pool = std::move(thread_pool_); in DeleteThreadPool()
2803 return thread_pool_.get(); in AcquireThreadPool()
|
| /art/runtime/gc/collector/ |
| D | mark_sweep.cc | 678 thread_pool_(thread_pool), in MarkStackTask()
769 ThreadPool* const thread_pool_; member in art::gc::collector::MarkSweep::MarkStackTask
780 auto* task = new MarkStackTask(thread_pool_, in MarkStackPush()
784 thread_pool_->AddTask(Thread::Current(), task); in MarkStackPush()
|
| /art/dex2oat/driver/ |
| D | compiler_driver.cc | 1410 thread_pool_(thread_pool) {} in ParallelCompilationManager()
1449 thread_pool_->AddTask(self, new ForAllClosureLambda<Fn>(this, end, fn)); in ForAllLambda()
1451 thread_pool_->StartWorkers(self); in ForAllLambda()
1458 thread_pool_->Wait(self, true, false); in ForAllLambda()
1461 thread_pool_->StopWorkers(self); in ForAllLambda()
1504 ThreadPool* const thread_pool_; member in art::ParallelCompilationManager
|
| /art/runtime/gc/ |
| D | heap.h | 744 return thread_pool_.get(); in GetThreadPool()
1404 std::unique_ptr<ThreadPool> thread_pool_; variable
|
| D | heap.cc | 1005 thread_pool_.reset(new ThreadPool("Heap thread pool", num_threads)); in CreateThreadPool()
1021 thread_pool_.reset(nullptr); in DeleteThreadPool()
|