Searched defs:lock (Results 1 – 12 of 12) sorted by relevance
37 std::lock_guard<std::mutex> lock(workersMutex_); in ~TaskManager() local44 std::unique_lock<std::shared_mutex> lock(taskInfosMutex_); in ~TaskManager() local55 std::unique_lock<std::mutex> lock(idMutex_); in GenerateTaskId() local61 std::unique_lock<std::mutex> lock(idMutex_); in GenerateExecuteId() local67 std::unique_lock<std::shared_mutex> lock(taskInfosMutex_); in StoreTaskInfo() local73 std::unique_lock<std::shared_mutex> lock(taskStatesMutex_); in StoreStateInfo() local79 std::unique_lock<std::shared_mutex> lock(runningInfosMutex_); in StoreRunningInfo() local91 std::unique_lock<std::shared_mutex> lock(taskInfosMutex_); in PopTaskInfo() local105 std::unique_lock<std::shared_mutex> lock(runningInfosMutex_); in PopRunningInfo() local115 std::shared_lock<std::shared_mutex> lock(taskStatesMutex_); in QueryState() local[all …]
21 std::unique_lock<std::mutex> lock(mtx_); in EnqueueTask() local27 std::unique_lock<std::mutex> lock(mtx_); in DequeueTask() local39 std::unique_lock<std::mutex> lock(mtx_); in IsEmpty() local
28 lock_guard<mutex> lock(mutex_); in AddObserver() local38 lock_guard<mutex> lock(mutex_); in RemoveObserver() local44 lock_guard<mutex> lock(mutex_); in RemoveAllObservers() local55 lock_guard<mutex> lock(mutex_); in GetObserversCount() local68 lock_guard<mutex> lock(mutex_); in NotifyObservers() local
64 std::unique_lock<std::mutex> lock(mutex_); in Stop() local79 std::unique_lock<std::mutex> lock(mutex_); in AddTask() local91 std::unique_lock<std::mutex> lock(mutex_); in GetCurTaskNum() local98 std::unique_lock<std::mutex> lock(mutex_); in ScheduleTask() local
53 std::lock_guard<std::mutex> lock(mutex_); in Shutdown() local69 std::lock_guard<std::mutex> lock(mutex_); in Register() local102 std::lock_guard<std::mutex> lock(mutex_); in Unregister() local168 std::lock_guard<std::mutex> lock(mutex_); in OnTimer() local227 std::lock_guard<std::mutex> lock(mutex_); in EraseUnusedTimerId() local
72 std::lock_guard<std::recursive_mutex> lock(mutex_); in CleanUp() local104 std::lock_guard<std::recursive_mutex> lock(mutex_); in ScheduleTimer() local121 std::lock_guard<std::recursive_mutex> lock(mutex_); in CancelTimer() local
70 std::lock_guard<std::recursive_mutex> lock(mutex_); in UpdateEventHandler() local94 std::lock_guard<std::recursive_mutex> lock(mutex_); in RemoveEventHandler() local
141 std::lock_guard<std::mutex> lock(trackerMutex); in GetNewTrace() local150 std::lock_guard<std::mutex> lock(trackerMutex); in PrintTracker() local
89 std::lock_guard<std::mutex> lock(timeLock); in ClearTimer() local124 std::lock_guard<std::mutex> lock(timeLock); in TimerCallback() local181 std::lock_guard<std::mutex> lock(timeLock); in SetTimeoutInner() local199 std::lock_guard<std::mutex> lock(timeLock); in ClearEnvironmentTimer() local
120 std::lock_guard<std::mutex> lock(g_newWorkersMutex); in WorkerConstructor() local192 std::lock_guard<std::recursive_mutex> lock(worker->liveStatusLock_); in WorkerConstructor() local798 std::lock_guard<std::recursive_mutex> lock(worker->liveStatusLock_); in ExecuteInThread() local841 std::lock_guard<std::recursive_mutex> lock(worker->liveStatusLock_); in ExecuteInThread() local855 std::lock_guard<std::recursive_mutex> lock(liveStatusLock_); in PrepareForWorkerInstance() local1261 std::lock_guard<std::recursive_mutex> lock(liveStatusLock_); in HandleException() local1279 std::lock_guard<std::recursive_mutex> lock(liveStatusLock_); in PostMessageToHostInner() local1410 std::lock_guard<std::recursive_mutex> lock(liveStatusLock_); in CloseWorkerCallback() local1431 std::lock_guard<std::mutex> lock(g_newWorkersMutex); in ReleaseWorkerThreadContent() local
102 std::lock_guard<std::recursive_mutex> lock(liveStatusLock_); in PrepareForWorkerInstance() local190 std::lock_guard<std::recursive_mutex> lock(worker->liveStatusLock_); in ExecuteInThread() local233 std::lock_guard<std::recursive_mutex> lock(worker->liveStatusLock_); in ExecuteInThread() local474 std::lock_guard<std::recursive_mutex> lock(liveStatusLock_); in HandleException() local622 std::lock_guard<std::recursive_mutex> lock(liveStatusLock_); in PostMessageToHostInner() local745 std::lock_guard<std::mutex> lock(g_workersMutex); in WorkerConstructor() local802 std::lock_guard<std::recursive_mutex> lock(worker->liveStatusLock_); in WorkerConstructor() local1189 std::lock_guard<std::recursive_mutex> lock(liveStatusLock_); in CloseWorkerCallback() local1227 std::lock_guard<std::mutex> lock(g_workersMutex); in ReleaseWorkerThreadContent() local
278 std::lock_guard<std::mutex> lock(mutexLast_); in OnLastStrongRef() local