Searched refs:TaskGroup (Results 1 – 6 of 6) sorted by relevance
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| D | task_group.h | 32 class TaskGroup {
34 TaskGroup() = default;
35 ~TaskGroup() = default;
45 TaskGroup(const TaskGroup &) = delete;
46 TaskGroup& operator=(const TaskGroup &) = delete;
47 TaskGroup(TaskGroup &&) = delete;
48 TaskGroup& operator=(TaskGroup &&) = delete;
|
| D | task_group.cpp | 27 napi_value TaskGroup::TaskGroupConstructor(napi_env env, napi_callback_info cbinfo) in TaskGroupConstructor()
48 TaskGroup* group = new TaskGroup(); in TaskGroupConstructor()
64 void TaskGroup::TaskGroupDestructor(napi_env env, void* data, [[maybe_unused]] void* hint) in TaskGroupDestructor()
66 TaskGroup* group = static_cast<TaskGroup*>(data); in TaskGroupDestructor()
71 napi_value TaskGroup::AddTask(napi_env env, napi_callback_info cbinfo) in AddTask()
87 TaskGroup* group = TaskGroupManager::GetInstance().GetTaskGroup(groupId); in AddTask()
120 uint32_t TaskGroup::GetTaskIndex(uint32_t taskId) in GetTaskIndex()
132 void TaskGroup::NotifyGroupTask(napi_env env) in NotifyGroupTask()
161 void TaskGroup::CancelPendingGroup(napi_env env) in CancelPendingGroup()
|
| D | task_manager.h | 56 class TaskGroup; variable
203 void StoreTaskGroup(uint64_t groupId, TaskGroup* taskGroup);
205 TaskGroup* GetTaskGroup(uint64_t groupId);
207 void CancelGroupTask(napi_env env, uint64_t taskId, TaskGroup* group);
208 void ReleaseTaskGroupData(napi_env env, TaskGroup* group);
224 std::unordered_map<uint64_t, TaskGroup*> taskGroups_ {};
|
| D | task_manager.cpp | 1038 auto taskGroup = reinterpret_cast<TaskGroup*>(groupIter->second); in AddTask()
1044 void TaskGroupManager::ReleaseTaskGroupData(napi_env env, TaskGroup* group) in ReleaseTaskGroupData()
1058 TaskGroup* taskGroup = GetTaskGroup(groupId); in CancelGroup()
1088 void TaskGroupManager::CancelGroupTask(napi_env env, uint64_t taskId, TaskGroup* group) in CancelGroupTask()
1195 void TaskGroupManager::StoreTaskGroup(uint64_t groupId, TaskGroup* taskGroup) in StoreTaskGroup()
1207 TaskGroup* TaskGroupManager::GetTaskGroup(uint64_t groupId) in GetTaskGroup()
1214 return reinterpret_cast<TaskGroup*>(groupIter->second); in GetTaskGroup()
1219 TaskGroup* group = GetTaskGroup(groupId); in UpdateGroupState()
|
| D | taskpool.cpp | 45 …napi_define_class(env, "TaskGroup", NAPI_AUTO_LENGTH, TaskGroup::TaskGroupConstructor, nullptr, 0,… in InitTaskPool()
393 TaskGroup* taskGroup = TaskGroupManager::GetInstance().GetTaskGroup(task->groupId_); in UpdateGroupInfoByResult()
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
| D | test_taskpool.cpp | 117 …napi_create_function(env, funcName.c_str(), funcName.size(), TaskGroup::TaskGroupConstructor, null…
129 …napi_create_function(env, funcName.c_str(), funcName.size(), TaskGroup::TaskGroupConstructor, null…
138 napi_create_function(env, funcName.c_str(), funcName.size(), TaskGroup::AddTask, nullptr, &cb);
282 TaskGroup* group = new TaskGroup();
297 TaskGroup* group = new TaskGroup();
299 TaskGroup* taskGroup = taskGroupManager.GetTaskGroup(groupId);
|