Searched refs:TaskGroupManager (Results 1 – 7 of 7) sorted by relevance
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| D | task_manager.h | 192 friend class TaskGroupManager; variable
195 class TaskGroupManager {
197 TaskGroupManager() = default;
198 ~TaskGroupManager() = default;
200 static TaskGroupManager &GetInstance();
218 TaskGroupManager(const TaskGroupManager &) = delete;
219 TaskGroupManager& operator=(const TaskGroupManager &) = delete;
220 TaskGroupManager(TaskGroupManager &&) = delete;
221 TaskGroupManager& operator=(TaskGroupManager &&) = delete;
|
| D | sequence_runner.cpp | 55 TaskGroupManager::GetInstance().StoreSequenceRunner(seqRunnerId, seqRunner); in SeqRunnerConstructor()
67 TaskGroupManager::GetInstance().StoreSequenceRunner(seqRunnerId, seqRunner); in SeqRunnerConstructor()
94 SequenceRunner* seqRunner = TaskGroupManager::GetInstance().GetSeqRunner(seqRunnerId); in Execute()
121 TaskGroupManager::GetInstance().AddTaskToSeqRunner(seqRunnerId, task); in Execute()
135 TaskGroupManager::GetInstance().RemoveSequenceRunner(seqRunner->seqRunnerId_); in SequnceRunnerDestructor()
|
| D | task_group.cpp | 51 TaskGroupManager::GetInstance().StoreTaskGroup(groupId, group); in TaskGroupConstructor()
67 TaskGroupManager::GetInstance().ReleaseTaskGroupData(env, group); in TaskGroupDestructor()
87 TaskGroup* group = TaskGroupManager::GetInstance().GetTaskGroup(groupId); in AddTask()
102 TaskGroupManager::GetInstance().AddTask(groupId, task->taskRef_, task->taskId_); in AddTask()
113 TaskGroupManager::GetInstance().AddTask(groupId, task->taskRef_, task->taskId_); in AddTask()
|
| D | task_manager.cpp | 1026 TaskGroupManager& TaskGroupManager::GetInstance() in GetInstance()
1028 static TaskGroupManager groupManager; in GetInstance()
1032 void TaskGroupManager::AddTask(uint64_t groupId, napi_ref taskRef, uint64_t taskId) in AddTask()
1044 void TaskGroupManager::ReleaseTaskGroupData(napi_env env, TaskGroup* group) in ReleaseTaskGroupData()
1046 TaskGroupManager::GetInstance().RemoveTaskGroup(group->groupId_); in ReleaseTaskGroupData()
1056 void TaskGroupManager::CancelGroup(napi_env env, uint64_t groupId) in CancelGroup()
1088 void TaskGroupManager::CancelGroupTask(napi_env env, uint64_t taskId, TaskGroup* group) in CancelGroupTask()
1119 void TaskGroupManager::StoreSequenceRunner(uint64_t seqRunnerId, SequenceRunner* seqRunner) in StoreSequenceRunner()
1125 void TaskGroupManager::RemoveSequenceRunner(uint64_t seqRunnerId) in RemoveSequenceRunner()
1131 SequenceRunner* TaskGroupManager::GetSeqRunner(uint64_t seqRunnerId) in GetSeqRunner()
[all …]
|
| D | taskpool.cpp | 291 auto taskGroup = TaskGroupManager::GetInstance().GetTaskGroup(groupId); in ExecuteGroup()
376 if (!TaskGroupManager::GetInstance().TriggerSeqRunner(task->env_, task)) { in TriggerTask()
393 TaskGroup* taskGroup = TaskGroupManager::GetInstance().GetTaskGroup(task->groupId_); in UpdateGroupInfoByResult()
476 TaskGroupManager::GetInstance().CancelGroup(env, groupId); in Cancel()
|
| D | worker.cpp | 294 TaskGroupManager::GetInstance().UpdateGroupState(task->groupId_); in PerformTask()
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
| D | test_taskpool.cpp | 281 TaskGroupManager &taskGroupManager = TaskGroupManager::GetInstance();
296 TaskGroupManager &taskGroupManager = TaskGroupManager::GetInstance();
|