Searched refs:thread_pool_ (Results 1 – 11 of 11) sorted by relevance
| /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 | 51 : thread_pool_(thread_pool), in ThreadPoolWorker()
102 thread_pool_->creation_barier_.Pass(self); in Run()
103 while ((task = thread_pool_->GetTask(self)) != nullptr) { in Run()
121 worker->thread_pool_->create_peers_ ? runtime->GetSystemThreadGroup() : nullptr, in Callback()
122 worker->thread_pool_->create_peers_)); in Callback()
|
| D | thread_pool.h | 96 ThreadPool* const thread_pool_; variable
|
| D | runtime.h | 941 return thread_pool_; in GetThreadPool()
945 ThreadPool* const thread_pool_;
1112 std::unique_ptr<ThreadPool> thread_pool_ GUARDED_BY(Locks::runtime_thread_pool_lock_);
|
| D | runtime.cc | 434 CHECK(thread_pool_ == nullptr); in ~Runtime()
1053 CHECK(thread_pool_ == nullptr); in InitNonZygoteOrPostFork()
1054 thread_pool_.reset(new ThreadPool("Runtime", num_workers, /*create_peers=*/false, kStackSize)); in InitNonZygoteOrPostFork()
1055 thread_pool_->StartWorkers(Thread::Current()); in InitNonZygoteOrPostFork()
2907 : thread_pool_(Runtime::Current()->AcquireThreadPool()) {} in ScopedThreadPoolUsage()
2920 thread_pool = std::move(thread_pool_); in DeleteThreadPool()
2929 return thread_pool_.get(); in AcquireThreadPool()
|
| /art/runtime/jit/ |
| D | jit.cc | 364 if (thread_pool_ != nullptr) { in WaitForWorkersToBeCreated()
365 thread_pool_->WaitForWorkersToBeCreated(); in WaitForWorkersToBeCreated()
371 if (thread_pool_ != nullptr) { in DeleteThreadPool()
377 pool = std::move(thread_pool_); in DeleteThreadPool()
1207 thread_pool_.reset(new ThreadPool("Jit thread pool", 1, kJitPoolNeedsPeers)); in CreateThreadPool()
1209 thread_pool_->SetPthreadPriority(options_->GetThreadPoolPthreadPriority()); in CreateThreadPool()
1227 thread_pool_->AddTask(Thread::Current(), new ZygoteVerificationTask()); in CreateThreadPool()
1233 thread_pool_->AddTask(Thread::Current(), new ZygoteTask()); in CreateThreadPool()
1315 thread_pool_->AddTask(Thread::Current(), new JitProfileTask(dex_files, class_loader)); in RegisterDexFiles()
1359 thread_pool_->AddTask(self, task); in CompileMethodFromProfile()
[all …]
|
| D | jit.h | 380 return thread_pool_.get(); in GetThreadPool()
488 std::unique_ptr<ThreadPool> thread_pool_; variable
|
| /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 | 1464 thread_pool_(thread_pool) {} in ParallelCompilationManager()
1503 thread_pool_->AddTask(self, new ForAllClosureLambda<Fn>(this, end, fn)); in ForAllLambda()
1505 thread_pool_->StartWorkers(self); in ForAllLambda()
1512 thread_pool_->Wait(self, true, false); in ForAllLambda()
1515 thread_pool_->StopWorkers(self); in ForAllLambda()
1558 ThreadPool* const thread_pool_; member in art::ParallelCompilationManager
|
| /art/runtime/gc/ |
| D | heap.h | 767 return thread_pool_.get(); in GetThreadPool()
1451 std::unique_ptr<ThreadPool> thread_pool_; variable
|
| D | heap.cc | 1017 thread_pool_.reset(new ThreadPool("Heap thread pool", num_threads)); in CreateThreadPool()
1033 thread_pool_.reset(nullptr); in DeleteThreadPool()
|