Lines Matching defs:worker
85 for (auto& worker : workers_) { in ~TaskManager() local
107 for (auto& worker : workers_) { in GetThreadInfos() local
159 Worker* worker = reinterpret_cast<Worker*>(taskInfo->worker); in GetTaskInfos() local
209 auto worker = *iter; in CheckForBlockedWorkers() local
255 … auto iter = std::find_if(idleWorkers_.begin(), idleWorkers_.end(), [this](Worker *worker) { in CreateOrDeleteWorkers()
269 auto worker = *iter; in CreateOrDeleteWorkers() local
594 void TaskManager::NotifyWorkerIdle(Worker* worker) in NotifyWorkerIdle()
605 void TaskManager::NotifyWorkerCreated(Worker* worker) in NotifyWorkerCreated()
611 void TaskManager::NotifyWorkerAdded(Worker* worker) in NotifyWorkerAdded()
634 return std::count_if(workers_.begin(), workers_.end(), [](const auto& worker) { in GetRunningWorkers()
703 Worker* worker = *candidator; in NotifyExecuteTask() local
729 auto worker = Worker::WorkerConstructor(env); in CreateWorkers() local
734 void TaskManager::RemoveWorker(Worker* worker) in RemoveWorker()