Searched refs:TaskGroupManager (Results 1 – 5 of 5) sorted by relevance
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| D | task_manager.h | 159 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;
|
| D | task_group.cpp | 33 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()
|
| D | task_manager.cpp | 761 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 …]
|
| D | taskpool.cpp | 150 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/ |
| D | test_taskpool.cpp | 360 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();
|