• Home
  • Raw
  • Download

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
669 void TaskManager::NotifyWorkerIdle(Worker* worker) in NotifyWorkerIdle()
684 void TaskManager::NotifyWorkerCreated(Worker* worker) in NotifyWorkerCreated()
689 void TaskManager::NotifyWorkerAdded(Worker* worker) in NotifyWorkerAdded()
696 void TaskManager::NotifyWorkerRunning(Worker* worker) in NotifyWorkerRunning()
706 return std::count_if(workers_.begin(), workers_.end(), [](const auto& worker) { in GetRunningWorkers()
811 for (auto& worker : workers_) { in IsChooseIdle() local
843 for (auto& worker : idleWorkers_) { in NotifyExecuteTask() local
892 auto worker = Worker::WorkerConstructor(env); in CreateWorkers() local
898 void TaskManager::RemoveWorker(Worker* worker) in RemoveWorker()
906 void TaskManager::RestoreWorker(Worker* worker) in RestoreWorker()
998 Worker* worker = static_cast<Worker*>(task->worker_); in NotifyCallbackExecute() local
1031 auto worker = info->worker; in GetMessageQueue() local
1044 auto worker = callbackInfo->worker; in GetMessageQueueFromCallbackInfo() local
1307 void TaskManager::StoreLongTaskInfo(uint64_t taskId, Worker* worker) in StoreLongTaskInfo()
1329 auto worker = GetLongTaskInfo(taskId); in TerminateTask() local