Lines Matching refs:thread_pool
673 MarkStackTask(ThreadPool* thread_pool, in MarkStackTask() argument
678 thread_pool_(thread_pool), in MarkStackTask()
831 CardScanTask(ThreadPool* thread_pool, in CardScanTask() argument
840 : MarkStackTask<false>(thread_pool, mark_sweep, mark_stack_size, mark_stack_obj), in CardScanTask()
882 ThreadPool* thread_pool = GetHeap()->GetThreadPool(); in ScanGrayObjects() local
933 auto* task = new CardScanTask(thread_pool, in ScanGrayObjects()
942 thread_pool->AddTask(self, task); in ScanGrayObjects()
950 thread_pool->SetMaxActiveWorkers(thread_count - 1); in ScanGrayObjects()
951 thread_pool->StartWorkers(self); in ScanGrayObjects()
952 thread_pool->Wait(self, true, true); in ScanGrayObjects()
953 thread_pool->StopWorkers(self); in ScanGrayObjects()
996 RecursiveMarkTask(ThreadPool* thread_pool, in RecursiveMarkTask() argument
1001 : MarkStackTask<false>(thread_pool, mark_sweep, 0, nullptr), in RecursiveMarkTask()
1034 ThreadPool* thread_pool = heap_->GetThreadPool(); in RecursiveMark() local
1061 auto* task = new RecursiveMarkTask(thread_pool, in RecursiveMark()
1066 thread_pool->AddTask(self, task); in RecursiveMark()
1068 thread_pool->SetMaxActiveWorkers(thread_count - 1); in RecursiveMark()
1069 thread_pool->StartWorkers(self); in RecursiveMark()
1070 thread_pool->Wait(self, true, true); in RecursiveMark()
1071 thread_pool->StopWorkers(self); in RecursiveMark()
1394 ThreadPool* thread_pool = GetHeap()->GetThreadPool(); in ProcessMarkStackParallel() local
1401 thread_pool->AddTask(self, new MarkStackTask<false>(thread_pool, this, delta, it)); in ProcessMarkStackParallel()
1404 thread_pool->SetMaxActiveWorkers(thread_count - 1); in ProcessMarkStackParallel()
1405 thread_pool->StartWorkers(self); in ProcessMarkStackParallel()
1406 thread_pool->Wait(self, true, true); in ProcessMarkStackParallel()
1407 thread_pool->StopWorkers(self); in ProcessMarkStackParallel()