Home
last modified time | relevance | path

Searched refs:RECURSIVE_MUTEX (Results 1 - 7 of 7) sorted by relevance

/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A Dtask_manager.cpp97 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in ~TaskManager()
116 std::lock_guard<RECURSIVE_MUTEX> lock(tasksMutex_); in ~TaskManager()
128 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in CountTraceForWorker()
143 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in GetThreadInfos()
180 std::lock_guard<RECURSIVE_MUTEX> lock(tasksMutex_); in GetTaskInfos()
188 std::lock_guard<RECURSIVE_MUTEX> lock(task->taskMutex_); in GetTaskInfos()
241 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in CheckForBlockedWorkers()
328 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in GetIdleWorkers()
430 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in GetIdleWorkers()
455 std::lock_guard<RECURSIVE_MUTEX> loc in NotifyShrink()
[all...]
H A Dtask_group.h62 RECURSIVE_MUTEX taskGroupMutex_ {};
H A Dtask.h56 #define RECURSIVE_MUTEX ffrt::recursive_mutex macro
60 #define RECURSIVE_MUTEX std::recursive_mutex macro
186 RECURSIVE_MUTEX taskMutex_ {};
H A Dtask.cpp112 std::lock_guard<RECURSIVE_MUTEX> lock(task->taskMutex_); in TaskDestructor()
132 std::lock_guard<RECURSIVE_MUTEX> lock(task->taskMutex_); in CleanupHookFunc()
246 std::lock_guard<RECURSIVE_MUTEX> lock(taskMutex_); in GetTaskInfo()
1040 std::lock_guard<RECURSIVE_MUTEX> lock(taskMutex_); in NotifyPendingTask()
1092 std::lock_guard<RECURSIVE_MUTEX> lock(taskMutex_); in DeserializeValue()
1351 std::lock_guard<RECURSIVE_MUTEX> lock(taskMutex_); in ClearDelayedTimers()
1387 std::lock_guard<RECURSIVE_MUTEX> lock(taskMutex_); in VerifyAndPostResult()
1395 std::lock_guard<RECURSIVE_MUTEX> lock(taskMutex_); in VerifyAndPostResult()
1416 std::lock_guard<RECURSIVE_MUTEX> lock(taskMutex_); in ShouldDeleteTask()
1449 std::lock_guard<RECURSIVE_MUTEX> loc in CheckStartExecution()
[all...]
H A Dtask_manager.h181 RECURSIVE_MUTEX tasksMutex_;
206 RECURSIVE_MUTEX workersMutex_;
H A Dtask_group.cpp145 std::lock_guard<RECURSIVE_MUTEX> lock(taskGroupMutex_); in NotifyGroupTask()
H A Dtaskpool.cpp303 std::lock_guard<RECURSIVE_MUTEX> lock(task->taskMutex_); in DelayTask()
349 std::lock_guard<RECURSIVE_MUTEX> lock(task->taskMutex_); in ExecuteDelayed()
382 std::lock_guard<RECURSIVE_MUTEX> lock(taskGroup->taskGroupMutex_); in ExecuteGroup()

Completed in 11 milliseconds