84         std::lock_guard<std::recursive_mutex> lock(workersMutex_);  in ~TaskManager()  local
92         std::unique_lock<std::shared_mutex> lock(taskInfosMutex_);  in ~TaskManager()  local
105         std::lock_guard<std::recursive_mutex> lock(workersMutex_);  in GetThreadInfos()  local
120                 std::lock_guard<std::mutex> lock(worker->currentTaskIdMutex_);  in GetThreadInfos()  local
146         std::unique_lock<std::shared_mutex> lock(taskInfosMutex_);  in GetTaskInfos()  local
205         std::lock_guard<std::recursive_mutex> lock(workersMutex_);  in CheckForBlockedWorkers()  local
251         std::lock_guard<std::recursive_mutex> lock(workersMutex_);  in CreateOrDeleteWorkers()  local
348     std::unique_lock<std::shared_mutex> lock(taskEnvInfoMutex_);  in StoreTaskEnvInfo()  local
359     std::unique_lock<std::shared_mutex> lock(taskEnvInfoMutex_);  in PopTaskEnvInfo()  local
370     std::shared_lock<std::shared_mutex> lock(taskEnvInfoMutex_);  in HasTaskEnvInfo()  local
376     std::unique_lock<std::shared_mutex> lock(taskInfosMutex_);  in StoreTaskInfo()  local
382     std::unique_lock<std::shared_mutex> lock(runningInfosMutex_);  in StoreRunningInfo()  local
394     std::unique_lock<std::shared_mutex> lock(taskInfosMutex_);  in PopTaskInfo()  local
408     std::unique_lock<std::shared_mutex> lock(taskInfosMutex_);  in GetTaskInfo()  local
418     std::unique_lock<std::shared_mutex> lock(taskInfosMutex_);  in MarkCanceledState()  local
432     std::unique_lock<std::shared_mutex> lock(runningInfosMutex_);  in PopRunningInfo()  local
442     std::unique_lock<std::shared_mutex> lock(executeStatesMutex_);  in AddExecuteState()  local
448     std::unique_lock<std::shared_mutex> lock(executeStatesMutex_);  in UpdateExecuteState()  local
462     std::unique_lock<std::shared_mutex> lock(executeStatesMutex_);  in RemoveExecuteState()  local
468     std::shared_lock<std::shared_mutex> lock(executeStatesMutex_);  in QueryExecuteState()  local
480     std::unique_lock<std::shared_mutex> lock(runningInfosMutex_);  in CancelTask()  local
597         std::lock_guard<std::recursive_mutex> lock(workersMutex_);  in NotifyWorkerIdle()  local
613     std::lock_guard<std::recursive_mutex> lock(workersMutex_);  in NotifyWorkerAdded()  local
619     std::lock_guard<std::recursive_mutex> lock(workersMutex_);  in TryTriggerLoadBalance()  local
627     std::lock_guard<std::recursive_mutex> lock(workersMutex_);  in GetIdleWorkers()  local
633     std::lock_guard<std::recursive_mutex> lock(workersMutex_);  in GetRunningWorkers()  local
641     std::lock_guard<std::recursive_mutex> lock(workersMutex_);  in GetTimeoutWorkers()  local
647     std::lock_guard<std::mutex> lock(taskQueuesMutex_);  in GetTaskNum()  local
654     std::lock_guard<std::recursive_mutex> lock(workersMutex_);  in GetThreadNum()  local
669         std::lock_guard<std::mutex> lock(taskQueuesMutex_);  in EnqueueExecuteId()  local
677     std::lock_guard<std::mutex> lock(taskQueuesMutex_);  in DequeueExecuteId()  local
698     std::lock_guard<std::recursive_mutex> lock(workersMutex_);  in NotifyExecuteTask()  local
736     std::lock_guard<std::recursive_mutex> lock(workersMutex_);  in RemoveWorker()  local
799     std::unique_lock<std::shared_mutex> lock(tasksMutex_);  in AddTask()  local
811     std::shared_lock<std::shared_mutex> lock(tasksMutex_);  in GetTasksByGroup()  local
822     std::unique_lock<std::shared_mutex> lock(tasksMutex_);  in ClearTasks()  local
835     std::lock_guard<std::mutex> lock(groupExecuteIdsMutex_);  in StoreExecuteId()  local
847     std::lock_guard<std::mutex> lock(groupExecuteIdsMutex_);  in RemoveExecuteId()  local
859     std::lock_guard<std::mutex> lock(groupExecuteIdsMutex_);  in ClearExecuteId()  local
865     std::lock_guard<std::mutex> lock(groupExecuteIdsMutex_);  in CancelGroup()  local
898     std::unique_lock<std::shared_mutex> lock(groupExecutionsMutex_);  in StoreRunningExecuteId()  local
904     std::unique_lock<std::shared_mutex> lock(groupExecutionsMutex_);  in RemoveRunningExecuteId()  local
910     std::shared_lock<std::shared_mutex> lock(groupExecutionsMutex_);  in IsRunning()  local
917     std::unique_lock<std::shared_mutex> lock(groupInfoMapMutex_);  in AddGroupInfoById()  local
923     std::unique_lock<std::shared_mutex> lock(groupInfoMapMutex_);  in RemoveGroupInfoById()  local
929     std::shared_lock<std::shared_mutex> lock(groupInfoMapMutex_);  in GetGroupInfoByExecutionId()  local