Home
last modified time | relevance | path

Searched refs:TaskGroupManager (Results 1 – 5 of 5) sorted by relevance

/commonlibrary/ets_utils/js_concurrent_module/taskpool/
Dtask_manager.h159 friend class TaskGroupManager; variable
162 class TaskGroupManager {
164 TaskGroupManager() = default;
165 ~TaskGroupManager() = default;
167 static TaskGroupManager &GetInstance();
184 TaskGroupManager(const TaskGroupManager &) = delete;
185 TaskGroupManager& operator=(const TaskGroupManager &) = delete;
186 TaskGroupManager(TaskGroupManager &&) = delete;
187 TaskGroupManager& operator=(TaskGroupManager &&) = delete;
Dtask_group.cpp33 uint32_t id = TaskGroupManager::GetInstance().GenerateGroupId(); in TaskGroupConstructor()
50 TaskGroupManager::GetInstance().ClearTasks(env, *groupId); in Destructor()
77 TaskGroupManager::GetInstance().AddTask(groupId, taskRef); in AddTask()
84 TaskGroupManager::GetInstance().AddTask(groupId, taskRef); in AddTask()
Dtask_manager.cpp761 TaskGroupManager &TaskGroupManager::GetInstance() in GetInstance()
763 static TaskGroupManager groupManager; in GetInstance()
767 uint32_t TaskGroupManager::GenerateGroupId() in GenerateGroupId()
772 GroupInfo* TaskGroupManager::GenerateGroupInfo(napi_env env, uint32_t taskNum, uint32_t groupId, in GenerateGroupInfo()
788 void TaskGroupManager::ClearGroupInfo(napi_env env, uint32_t groupExecuteId, GroupInfo* groupInfo) in ClearGroupInfo()
797 void TaskGroupManager::AddTask(uint32_t groupId, napi_ref task) in AddTask()
809 const std::list<napi_ref>& TaskGroupManager::GetTasksByGroup(uint32_t groupId) in GetTasksByGroup()
820 void TaskGroupManager::ClearTasks(napi_env env, uint32_t groupId) in ClearTasks()
833 void TaskGroupManager::StoreExecuteId(uint32_t groupId, uint32_t groupExecuteId) in StoreExecuteId()
845 void TaskGroupManager::RemoveExecuteId(uint32_t groupId, uint32_t groupExecuteId) in RemoveExecuteId()
[all …]
Dtaskpool.cpp150 TaskGroupManager& groupManager = TaskGroupManager::GetInstance(); in ExecuteGroup()
217 bool isRunning = TaskGroupManager::GetInstance().IsRunning(groupExecuteId); in UpdateGroupInfoByResult()
221 … GroupInfo* groupInfo = TaskGroupManager::GetInstance().GetGroupInfoByExecutionId(groupExecuteId); in UpdateGroupInfoByResult()
243 TaskGroupManager::GetInstance().RemoveExecuteId(groupInfo->groupId, groupExecuteId); in UpdateGroupInfoByResult()
244 TaskGroupManager::GetInstance().ClearGroupInfo(env, groupExecuteId, groupInfo); in UpdateGroupInfoByResult()
294 TaskGroupManager::GetInstance().CancelGroup(env, groupId); in Cancel()
295 TaskGroupManager::GetInstance().ClearExecuteId(groupId); in Cancel()
/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
Dtest_taskpool.cpp360 TaskGroupManager &taskGroupManager = TaskGroupManager::GetInstance();
437 TaskGroupManager &taskGroupManager = TaskGroupManager::GetInstance();
444 TaskGroupManager &taskGroupManager = TaskGroupManager::GetInstance();
452 TaskGroupManager &taskGroupManager = TaskGroupManager::GetInstance();
463 TaskGroupManager &taskGroupManager = TaskGroupManager::GetInstance();
472 TaskGroupManager &taskGroupManager = TaskGroupManager::GetInstance();
481 TaskGroupManager &taskGroupManager = TaskGroupManager::GetInstance();
498 TaskGroupManager &taskGroupManager = TaskGroupManager::GetInstance();
510 TaskGroupManager &taskGroupManager = TaskGroupManager::GetInstance();
518 TaskGroupManager &taskGroupManager = TaskGroupManager::GetInstance();