Lines Matching refs:delegate
204 void ScavengerCollector::JobTask::Run(JobDelegate* delegate) {
205 DCHECK_LT(delegate->GetTaskId(), scavengers_->size());
206 Scavenger* scavenger = (*scavengers_)[delegate->GetTaskId()].get();
207 if (delegate->IsJoiningThread()) {
210 ProcessItems(delegate, scavenger);
215 ProcessItems(delegate, scavenger);
230 void ScavengerCollector::JobTask::ProcessItems(JobDelegate* delegate,
236 scavenger->Process(delegate);
655 void Scavenger::Process(JobDelegate* delegate) {
667 if (delegate && ((++objects % kInterruptThreshold) == 0)) {
669 delegate->NotifyConcurrencyIncrease();
679 if (delegate && ((++objects % kInterruptThreshold) == 0)) {
681 delegate->NotifyConcurrencyIncrease();