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