74         std::lock_guard<std::recursive_mutex> lock(workersMutex_);  in ~TaskManager()  local
82         std::unique_lock<std::shared_mutex> lock(tasksMutex_);  in ~TaskManager()  local
94     std::lock_guard<std::recursive_mutex> lock(workersMutex_);  in CountTraceForWorker()  local
109         std::lock_guard<std::recursive_mutex> lock(workersMutex_);  in GetThreadInfos()  local
124                 std::lock_guard<std::mutex> lock(worker->currentTaskIdMutex_);  in GetThreadInfos()  local
148         std::unique_lock<std::shared_mutex> lock(tasksMutex_);  in GetTaskInfos()  local
156             std::unique_lock<std::shared_mutex> lock(task->taskMutex_);  in GetTaskInfos()  local
211     std::lock_guard<std::recursive_mutex> lock(workersMutex_);  in CheckForBlockedWorkers()  local
293     std::lock_guard<std::recursive_mutex> lock(workersMutex_);  in GetIdleWorkers()  local
361     std::lock_guard<std::recursive_mutex> lock(workersMutex_);  in GetIdleWorkers()  local
388         std::lock_guard<std::recursive_mutex> lock(workersMutex_);  in NotifyShrink()  local
394     std::lock_guard<std::recursive_mutex> lock(workersMutex_);  in NotifyShrink()  local
487     std::unique_lock<std::shared_mutex> lock(task->taskMutex_);  in CancelTask()  local
515         std::lock_guard<std::recursive_mutex> lock(workersMutex_);  in NotifyWorkerIdle()  local
539     std::lock_guard<std::recursive_mutex> lock(workersMutex_);  in NotifyWorkerAdded()  local
546     std::lock_guard<std::recursive_mutex> lock(workersMutex_);  in NotifyWorkerRunning()  local
553     std::lock_guard<std::recursive_mutex> lock(workersMutex_);  in GetRunningWorkers()  local
561     std::lock_guard<std::recursive_mutex> lock(workersMutex_);  in GetTimeoutWorkers()  local
567     std::lock_guard<std::mutex> lock(taskQueuesMutex_);  in GetTaskNum()  local
574     std::lock_guard<std::recursive_mutex> lock(workersMutex_);  in GetThreadNum()  local
581         std::lock_guard<std::mutex> lock(taskQueuesMutex_);  in EnqueueTaskId()  local
589     std::lock_guard<std::mutex> lock(taskQueuesMutex_);  in DequeueTaskId()  local
626     std::lock_guard<std::recursive_mutex> lock(workersMutex_);  in NotifyExecuteTask()  local
661     std::lock_guard<std::recursive_mutex> lock(workersMutex_);  in RemoveWorker()  local
668     std::lock_guard<std::recursive_mutex> lock(workersMutex_);  in RestoreWorker()  local
689     std::lock_guard<std::mutex> lock(callbackMutex_);  in RegisterCallback()  local
695     std::lock_guard<std::mutex> lock(callbackMutex_);  in GetCallbackInfo()  local
709     std::lock_guard<std::mutex> lock(callbackMutex_);  in IncreaseRefCount()  local
722     std::lock_guard<std::mutex> lock(callbackMutex_);  in DecreaseRefCount()  local
735     std::lock_guard<std::mutex> lock(callbackMutex_);  in NotifyCallbackExecute()  local
754     std::unique_lock<std::shared_mutex> lock(dependTaskInfosMutex_);  in NotifyDependencyTaskInfo()  local
761             std::unique_lock<std::shared_mutex> lock(tasksMutex_);  in NotifyDependencyTaskInfo()  local
788         std::unique_lock<std::shared_mutex> lock(tasksMutex_);  in IsDependendByTaskId()  local
798     std::unique_lock<std::shared_mutex> lock(dependTaskInfosMutex_);  in IsDependendByTaskId()  local
808     std::unique_lock<std::shared_mutex> lock(dependTaskInfosMutex_);  in StoreTaskDependency()  local
861     std::unique_lock<std::shared_mutex> lock(dependTaskInfosMutex_);  in RemoveTaskDependency()  local
880     std::unique_lock<std::shared_mutex> lock(pendingTaskInfosMutex_);  in EnqueuePendingTaskInfo()  local
886     std::unique_lock<std::shared_mutex> lock(pendingTaskInfosMutex_);  in DequeuePendingTaskInfo()  local
903     std::unique_lock<std::shared_mutex> lock(pendingTaskInfosMutex_);  in RemovePendingTaskInfo()  local
935     std::unique_lock<std::shared_mutex> lock(taskDurationInfosMutex_);  in StoreTaskDuration()  local
952     std::unique_lock<std::shared_mutex> lock(taskDurationInfosMutex_);  in GetTaskDuration()  local
969     std::unique_lock<std::shared_mutex> lock(taskDurationInfosMutex_);  in RemoveTaskDuration()  local
989     std::unique_lock<std::shared_mutex> lock(dependTaskInfosMutex_);  in ReleaseTaskData()  local
1005     std::unique_lock<std::shared_mutex> lock(tasksMutex_);  in StoreTask()  local
1011     std::unique_lock<std::shared_mutex> lock(tasksMutex_);  in RemoveTask()  local
1017     std::unique_lock<std::shared_mutex> lock(tasksMutex_);  in GetTask()  local
1064         std::unique_lock<std::shared_mutex> lock(taskGroup->taskGroupMutex_);  in CancelGroup()  local
1095     std::unique_lock<std::shared_mutex> lock(task->taskMutex_);  in CancelGroupTask()  local
1121     std::unique_lock<std::mutex> lock(seqRunnersMutex_);  in StoreSequenceRunner()  local
1127     std::unique_lock<std::mutex> lock(seqRunnersMutex_);  in RemoveSequenceRunner()  local
1133     std::unique_lock<std::mutex> lock(seqRunnersMutex_);  in GetSeqRunner()  local
1144     std::unique_lock<std::mutex> lock(seqRunnersMutex_);  in AddTaskToSeqRunner()  local
1169         std::unique_lock<std::shared_mutex> lock(seqRunner->seqRunnerMutex_);  in TriggerSeqRunner()  local
1197     std::lock_guard<std::mutex> lock(taskGroupsMutex_);  in StoreTaskGroup()  local
1203     std::lock_guard<std::mutex> lock(taskGroupsMutex_);  in RemoveTaskGroup()  local
1209     std::lock_guard<std::mutex> lock(taskGroupsMutex_);  in GetTaskGroup()  local