Home
last modified time | relevance | path

Searched refs:ThreadPool (Results 1 – 22 of 22) sorted by relevance

/art/runtime/
Dthread_pool.cc49 ThreadPoolWorker::ThreadPoolWorker(ThreadPool* thread_pool, const std::string& name, in ThreadPoolWorker()
132 void ThreadPool::AddTask(Thread* self, Task* task) { in AddTask()
141 void ThreadPool::RemoveAllTasks(Thread* self) { in RemoveAllTasks()
152 ThreadPool::ThreadPool(const char* name, in ThreadPool() function in art::ThreadPool
172 void ThreadPool::CreateThreads() { in CreateThreads()
189 void ThreadPool::WaitForWorkersToBeCreated() { in WaitForWorkersToBeCreated()
193 const std::vector<ThreadPoolWorker*>& ThreadPool::GetWorkers() { in GetWorkers()
199 void ThreadPool::DeleteThreads() { in DeleteThreads()
215 void ThreadPool::SetMaxActiveWorkers(size_t max_workers) { in SetMaxActiveWorkers()
221 ThreadPool::~ThreadPool() { in ~ThreadPool()
[all …]
Dthread_pool.h30 class ThreadPool; variable
92 ThreadPoolWorker(ThreadPool* thread_pool, const std::string& name, size_t stack_size);
96 ThreadPool* const thread_pool_;
103 friend class ThreadPool;
108 class ThreadPool {
135 ThreadPool(const char* name,
139 virtual ~ThreadPool();
207 DISALLOW_COPY_AND_ASSIGN(ThreadPool);
Dthread_pool_test.cc64 ThreadPool thread_pool("Thread pool test thread pool", num_threads); in TEST_F()
79 ThreadPool thread_pool("Thread pool test thread pool", num_threads); in TEST_F()
104 ThreadPool thread_pool("Thread pool test thread pool", num_threads); in TEST_F()
127 TreeTask(ThreadPool* const thread_pool, AtomicInteger* count, int depth) in TreeTask()
146 ThreadPool* const thread_pool_;
154 ThreadPool thread_pool("Thread pool test thread pool", num_threads); in TEST_F()
195 ThreadPool thread_pool("Thread pool test thread pool", 1); in TEST_F()
207 ThreadPool thread_pool("Thread pool test thread pool", 1, true); in TEST_F()
Dbarrier_test.cc63 ThreadPool thread_pool("Barrier test thread pool", num_threads); in TEST_F()
114 ThreadPool thread_pool("Barrier test thread pool", num_threads); in TEST_F()
Doat_file_manager.h42 class ThreadPool; variable
165 std::unique_ptr<ThreadPool> verification_thread_pool_;
Druntime.h109 class ThreadPool; variable
940 ThreadPool* GetThreadPool() const { in GetThreadPool()
945 ThreadPool* const thread_pool_;
1018 ThreadPool* AcquireThreadPool() REQUIRES(!Locks::runtime_thread_pool_lock_);
1112 std::unique_ptr<ThreadPool> thread_pool_ GUARDED_BY(Locks::runtime_thread_pool_lock_);
Dmonitor_test.cc269 ThreadPool thread_pool(pool_name, 3); in CommonWaitSetup()
350 ThreadPool thread_pool("the pool", 2); in TEST_F()
Doat_file_manager.cc772 new ThreadPool("Verification thread pool", /* num_threads= */ 1)); in RunBackgroundVerification()
Druntime.cc1054 thread_pool_.reset(new ThreadPool("Runtime", num_workers, /*create_peers=*/false, kStackSize)); in InitNonZygoteOrPostFork()
2916 std::unique_ptr<ThreadPool> thread_pool; in DeleteThreadPool()
2926 ThreadPool* Runtime::AcquireThreadPool() { in AcquireThreadPool()
Doat_file_assistant_test.cc1174 ThreadPool thread_pool("Oat file assistant test thread pool", kNumThreads); in TEST_F()
/art/dex2oat/driver/
Dcompiler_driver.h246 ThreadPool* thread_pool,
266 ThreadPool* thread_pool,
277 ThreadPool* thread_pool,
329 std::unique_ptr<ThreadPool> parallel_thread_pool_;
332 std::unique_ptr<ThreadPool> single_thread_pool_;
Dcompiler_driver.cc651 ThreadPool* resolve_thread_pool = force_determinism in Resolve()
1457 ThreadPool* thread_pool) in ParallelCompilationManager()
1558 ThreadPool* const thread_pool_;
1767 ThreadPool* thread_pool, in ResolveDexFile()
1940 ThreadPool* verify_thread_pool = in Verify()
2108 ThreadPool* thread_pool, in VerifyDexFile()
2178 ThreadPool* thread_pool, in SetVerifiedDexFile()
2602 ThreadPool* init_thread_pool = force_determinism in InitializeClasses()
2709 ThreadPool* thread_pool, in CompileDexFile()
2956 new ThreadPool("Compiler driver thread pool", parallel_count)); in InitializeThreadPools()
[all …]
/art/runtime/gc/
Dtask_processor_test.cc66 ThreadPool thread_pool("task processor test", 1U); in TEST_F()
136 ThreadPool thread_pool("task processor test", 1U); in TEST_F()
Dheap.h58 class ThreadPool; variable
766 ThreadPool* GetThreadPool() { in GetThreadPool()
1451 std::unique_ptr<ThreadPool> thread_pool_;
Dheap.cc1017 thread_pool_.reset(new ThreadPool("Heap thread pool", num_threads)); in CreateThreadPool()
/art/dex2oat/linker/
Delf_writer_quick.cc132 std::unique_ptr<ThreadPool> debug_info_thread_pool_;
260 debug_info_thread_pool_ = std::make_unique<ThreadPool>("Mini-debug-info writer", 1); in PrepareDebugInfo()
/art/runtime/jit/
Djit.h379 ThreadPool* GetThreadPool() const { in GetThreadPool()
488 std::unique_ptr<ThreadPool> thread_pool_;
Djit.cc372 std::unique_ptr<ThreadPool> pool; in DeleteThreadPool()
1207 thread_pool_.reset(new ThreadPool("Jit thread pool", 1, kJitPoolNeedsPeers)); in CreateThreadPool()
Djit_code_cache.cc1943 ThreadPool* pool = Runtime::Current()->GetJit()->GetThreadPool(); in PostForkChildAction()
/art/runtime/gc/collector/
Dmark_sweep.cc673 MarkStackTask(ThreadPool* thread_pool, in MarkStackTask()
769 ThreadPool* const thread_pool_;
831 CardScanTask(ThreadPool* thread_pool, in CardScanTask()
882 ThreadPool* thread_pool = GetHeap()->GetThreadPool(); in ScanGrayObjects()
996 RecursiveMarkTask(ThreadPool* thread_pool, in RecursiveMarkTask()
1034 ThreadPool* thread_pool = heap_->GetThreadPool(); in RecursiveMark()
1394 ThreadPool* thread_pool = GetHeap()->GetThreadPool(); in ProcessMarkStackParallel()
/art/runtime/gc/space/
Dlarge_object_space_test.cc164 ThreadPool thread_pool("Large object space test thread pool", kNumThreads); in RaceTest()
Dimage_space.cc1207 ThreadPool* const pool = stpu.GetThreadPool(); in LoadImageFile()