Lines Matching refs:thread_pool

552   MarkStackTask(ThreadPool* thread_pool, MarkSweep* mark_sweep, size_t mark_stack_size,  in MarkStackTask()  argument
555 thread_pool_(thread_pool), in MarkStackTask()
682 CardScanTask(ThreadPool* thread_pool, MarkSweep* mark_sweep, in CardScanTask() argument
686 : MarkStackTask<false>(thread_pool, mark_sweep, mark_stack_size, mark_stack_obj), in CardScanTask()
727 ThreadPool* thread_pool = GetHeap()->GetThreadPool(); in ScanGrayObjects() local
773 auto* task = new CardScanTask(thread_pool, this, space->GetMarkBitmap(), card_begin, in ScanGrayObjects()
776 thread_pool->AddTask(self, task); in ScanGrayObjects()
784 thread_pool->SetMaxActiveWorkers(thread_count - 1); in ScanGrayObjects()
785 thread_pool->StartWorkers(self); in ScanGrayObjects()
786 thread_pool->Wait(self, true, true); in ScanGrayObjects()
787 thread_pool->StopWorkers(self); in ScanGrayObjects()
817 RecursiveMarkTask(ThreadPool* thread_pool, MarkSweep* mark_sweep, in RecursiveMarkTask() argument
819 : MarkStackTask<false>(thread_pool, mark_sweep, 0, NULL), bitmap_(bitmap), begin_(begin), in RecursiveMarkTask()
851 ThreadPool* thread_pool = heap_->GetThreadPool(); in RecursiveMark() local
878 auto* task = new RecursiveMarkTask(thread_pool, this, current_space_bitmap_, start, in RecursiveMark()
880 thread_pool->AddTask(self, task); in RecursiveMark()
882 thread_pool->SetMaxActiveWorkers(thread_count - 1); in RecursiveMark()
883 thread_pool->StartWorkers(self); in RecursiveMark()
884 thread_pool->Wait(self, true, true); in RecursiveMark()
885 thread_pool->StopWorkers(self); in RecursiveMark()
1168 ThreadPool* thread_pool = GetHeap()->GetThreadPool(); in ProcessMarkStackParallel() local
1175 thread_pool->AddTask(self, new MarkStackTask<false>(thread_pool, this, delta, it)); in ProcessMarkStackParallel()
1178 thread_pool->SetMaxActiveWorkers(thread_count - 1); in ProcessMarkStackParallel()
1179 thread_pool->StartWorkers(self); in ProcessMarkStackParallel()
1180 thread_pool->Wait(self, true, true); in ProcessMarkStackParallel()
1181 thread_pool->StopWorkers(self); in ProcessMarkStackParallel()