Home
last modified time | relevance | path

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

/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A Dtask_manager.h244 friend class TaskGroupManager; variable
248 class TaskGroupManager {
250 TaskGroupManager() = default;
251 ~TaskGroupManager() = default;
253 static TaskGroupManager &GetInstance();
272 TaskGroupManager(const TaskGroupManager &) = delete;
273 TaskGroupManager& operator=(const TaskGroupManager &) = delete;
274 TaskGroupManager(TaskGroupManager &&) = delete;
275 TaskGroupManager& operator=(TaskGroupManager &&) = delete;
H A Dtask_group.cpp53 TaskGroupManager::GetInstance().StoreTaskGroup(groupId, group); in TaskGroupConstructor()
64 TaskGroupManager::GetInstance().RemoveTaskGroup(group->groupId_); in TaskGroupConstructor()
79 TaskGroupManager::GetInstance().ReleaseTaskGroupData(env, group);
101 TaskGroup* group = TaskGroupManager::GetInstance().GetTaskGroup(groupId); in AddTask()
124 TaskGroupManager::GetInstance().AddTask(groupId, task->taskRef_, task->taskId_); in AddTask()
142 TaskGroupManager::GetInstance().AddTask(groupId, task->taskRef_, task->taskId_); in AddTask()
228 TaskGroupManager::GetInstance().CancelGroupTask(env, taskId, this); in CancelGroupTask()
H A Dsequence_runner.cpp35 TaskGroupManager::GetInstance().StoreSequenceRunner(seqRunnerId, seqRunner); in SeqRunnerConstructorInner()
134 SequenceRunner* seqRunner = TaskGroupManager::GetInstance().GetSeqRunner(seqRunnerId); in Execute()
165 TaskGroupManager::GetInstance().AddTaskToSeqRunner(seqRunnerId, task); in Execute()
181 TaskGroupManager::GetInstance().RemoveSequenceRunner(seqRunner->seqRunnerId_);
H A Dtask_manager.cpp1492 TaskGroupManager& TaskGroupManager::GetInstance() in GetInstance()
1494 static TaskGroupManager groupManager; in GetInstance()
1519 TaskGroupManager::GetInstance().RemoveTaskGroup(group->groupId_); in ReleaseTaskGroupData()
1539 void TaskGroupManager::CancelGroup(napi_env env, uint64_t groupId) in CancelGroup()
1612 void TaskGroupManager::RemoveSequenceRunner(uint64_t seqRunnerId) in RemoveSequenceRunner()
1618 SequenceRunner* TaskGroupManager::GetSeqRunner(uint64_t seqRunnerId) in GetSeqRunner()
1642 bool TaskGroupManager::TriggerSeqRunner(napi_env env, Task* lastTask) in TriggerSeqRunner()
1688 void TaskGroupManager::DisposeCanceledTask(napi_env env, Task* task) in DisposeCanceledTask()
1704 void TaskGroupManager::RemoveTaskGroup(uint64_t groupId) in RemoveTaskGroup()
1710 TaskGroup* TaskGroupManager::GetTaskGroup(uint64_t groupId) in GetTaskGroup()
[all …]
H A Dtaskpool.cpp385 auto taskGroup = TaskGroupManager::GetInstance().GetTaskGroup(groupId); in ExecuteGroup()
515 if (!TaskGroupManager::GetInstance().TriggerSeqRunner(task->env_, task)) { in TriggerTask()
543 TaskGroup* taskGroup = TaskGroupManager::GetInstance().GetTaskGroup(task->groupId_); in UpdateGroupInfoByResult()
645 TaskGroupManager::GetInstance().CancelGroup(env, groupId); in Cancel()
H A Dworker.cpp398 … if (task->IsGroupTask() && (!TaskGroupManager::GetInstance().UpdateGroupState(task->groupId_))) { in PerformTask()
/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
H A Dtest_taskpool.cpp386 TaskGroupManager &taskGroupManager = TaskGroupManager::GetInstance();
401 TaskGroupManager &taskGroupManager = TaskGroupManager::GetInstance();
747 TaskGroupManager& taskGroupManager = TaskGroupManager::GetInstance();
756 TaskGroupManager& taskGroupManager = TaskGroupManager::GetInstance();
765 TaskGroupManager& taskGroupManager = TaskGroupManager::GetInstance();
774 TaskGroupManager& taskGroupManager = TaskGroupManager::GetInstance();
783 TaskGroupManager& taskGroupManager = TaskGroupManager::GetInstance();
792 TaskGroupManager& taskGroupManager = TaskGroupManager::GetInstance();
906 TaskGroupManager& taskGroupManager = TaskGroupManager::GetInstance();
922 TaskGroupManager& taskGroupManager = TaskGroupManager::GetInstance();
[all …]
H A Dtest.cpp607 TaskGroupManager& groupManager = TaskGroupManager::GetInstance(); in CheckTask()
649 TaskGroupManager& groupManager = TaskGroupManager::GetInstance(); in CancelGroupTask()
675 TaskGroupManager& groupManager = TaskGroupManager::GetInstance(); in TriggerSeqRunner()
714 TaskGroupManager& groupManager = TaskGroupManager::GetInstance(); in UpdateGroupState()
805 TaskGroupManager& groupManager = TaskGroupManager::GetInstance(); in PerformTask()