Lines Matching refs:thread_pool
651 MarkStackTask(ThreadPool* thread_pool,
656 thread_pool_(thread_pool),
809 CardScanTask(ThreadPool* thread_pool,
818 : MarkStackTask<false>(thread_pool, mark_sweep, mark_stack_size, mark_stack_obj),
860 ThreadPool* thread_pool = GetHeap()->GetThreadPool();
911 auto* task = new CardScanTask(thread_pool,
920 thread_pool->AddTask(self, task);
928 thread_pool->SetMaxActiveWorkers(thread_count - 1);
929 thread_pool->StartWorkers(self);
930 thread_pool->Wait(self, true, true);
931 thread_pool->StopWorkers(self);
974 RecursiveMarkTask(ThreadPool* thread_pool,
979 : MarkStackTask<false>(thread_pool, mark_sweep, 0, nullptr),
1012 ThreadPool* thread_pool = heap_->GetThreadPool();
1039 auto* task = new RecursiveMarkTask(thread_pool,
1044 thread_pool->AddTask(self, task);
1046 thread_pool->SetMaxActiveWorkers(thread_count - 1);
1047 thread_pool->StartWorkers(self);
1048 thread_pool->Wait(self, true, true);
1049 thread_pool->StopWorkers(self);
1373 ThreadPool* thread_pool = GetHeap()->GetThreadPool();
1380 thread_pool->AddTask(self, new MarkStackTask<false>(thread_pool, this, delta, it));
1383 thread_pool->SetMaxActiveWorkers(thread_count - 1);
1384 thread_pool->StartWorkers(self);
1385 thread_pool->Wait(self, true, true);
1386 thread_pool->StopWorkers(self);