Lines Matching defs:worker

98         for (auto& worker : workers_) {  in ~TaskManager()  local
145 for (auto& worker : workers_) { in GetThreadInfos() local
246 auto worker = *iter; in CheckForBlockedWorkers() local
329 for (auto& worker : idleWorkers_) { in GetIdleWorkers() local
361 for (auto& worker : idleWorkers_) { in GetIdleWorkersList() local
409 auto worker = freeList_[i]; in TriggerShrink() local
437 auto iter = std::find_if(idleWorkers_.begin(), idleWorkers_.end(), [](Worker *worker) { in TriggerShrink()
443 auto worker = *iter; in TriggerShrink() local
482 auto worker = *(idleWorkers_.begin()); in NotifyShrink() local
670 void TaskManager::NotifyWorkerIdle(Worker* worker) in NotifyWorkerIdle()
685 void TaskManager::NotifyWorkerCreated(Worker* worker) in NotifyWorkerCreated()
690 void TaskManager::NotifyWorkerAdded(Worker* worker) in NotifyWorkerAdded()
697 void TaskManager::NotifyWorkerRunning(Worker* worker) in NotifyWorkerRunning()
707 return std::count_if(workers_.begin(), workers_.end(), [](const auto& worker) { in GetRunningWorkers()
812 for (auto& worker : workers_) { in IsChooseIdle() local
844 for (auto& worker : idleWorkers_) { in NotifyExecuteTask() local
889 auto worker = Worker::WorkerConstructor(env); in CreateWorkers() local
895 void TaskManager::RemoveWorker(Worker* worker) in RemoveWorker()
903 void TaskManager::RestoreWorker(Worker* worker) in RestoreWorker()
995 Worker* worker = static_cast<Worker*>(task->worker_); in NotifyCallbackExecute() local
1028 auto worker = info->worker; in GetMessageQueue() local
1041 auto worker = callbackInfo->worker; in GetMessageQueueFromCallbackInfo() local
1304 void TaskManager::StoreLongTaskInfo(uint64_t taskId, Worker* worker) in StoreLongTaskInfo()
1326 auto worker = GetLongTaskInfo(taskId); in TerminateTask() local