Searched refs:TaskGroup (Results 1 - 7 of 7) sorted by relevance
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| H A D | task_group.h | 32 class TaskGroup { class
34 TaskGroup() = default;
35 ~TaskGroup() = default;
45 TaskGroup(const TaskGroup &) = delete;
46 TaskGroup& operator=(const TaskGroup &) = delete;
47 TaskGroup(TaskGroup &&) = delete;
48 TaskGroup
[all...] |
| H A 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()
67 TaskGroup* group = static_cast<TaskGroup*>(data); in TaskGroupDestructor()
73 napi_value TaskGroup::AddTask(napi_env env, napi_callback_info cbinfo) in AddTask()
89 TaskGroup* group = TaskGroupManager::GetInstance().GetTaskGroup(groupId); in AddTask()
130 uint32_t TaskGroup::GetTaskIndex(uint32_t taskId) in GetTaskIndex()
142 void TaskGroup
[all...] |
| H A D | task_manager.h | 55 class TaskGroup;
252 void StoreTaskGroup(uint64_t groupId, TaskGroup* taskGroup);
254 TaskGroup* GetTaskGroup(uint64_t groupId);
256 void CancelGroupTask(napi_env env, uint64_t taskId, TaskGroup* group);
257 void ReleaseTaskGroupData(napi_env env, TaskGroup* group);
273 // <groupId, TaskGroup>
274 std::unordered_map<uint64_t, TaskGroup*> taskGroups_ {};
|
| H A D | task_manager.cpp | 1474 auto taskGroup = reinterpret_cast<TaskGroup*>(groupIter->second); in AddTask()
1484 void TaskGroupManager::ReleaseTaskGroupData(napi_env env, TaskGroup* group) in ReleaseTaskGroupData()
1508 TaskGroup* taskGroup = GetTaskGroup(groupId); in CancelGroup()
1546 void TaskGroupManager::CancelGroupTask(napi_env env, uint64_t taskId, TaskGroup* group) in CancelGroupTask()
1657 void TaskGroupManager::StoreTaskGroup(uint64_t groupId, TaskGroup* taskGroup) in StoreTaskGroup()
1669 TaskGroup* TaskGroupManager::GetTaskGroup(uint64_t groupId) in GetTaskGroup()
1676 return reinterpret_cast<TaskGroup*>(groupIter->second); in GetTaskGroup()
1689 TaskGroup* group = reinterpret_cast<TaskGroup*>(groupIter->second); in UpdateGroupState()
|
| H A D | taskpool.cpp | 51 napi_define_class(env, "TaskGroup", NAPI_AUTO_LENGTH, TaskGroup::TaskGroupConstructor, nullptr, 0, nullptr,
in InitTaskPool()
87 DECLARE_NAPI_PROPERTY("TaskGroup", taskGroupClass),
in InitTaskPool()
515 TaskGroup* taskGroup = TaskGroupManager::GetInstance().GetTaskGroup(task->groupId_);
in UpdateGroupInfoByResult()
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
| H A D | test_taskpool.cpp | 59 napi_create_function(env, funcName.c_str(), funcName.size(), TaskGroup::TaskGroupConstructor, nullptr, &cb); in GeneratorTaskGroup()
72 napi_create_function(env, funcName.c_str(), funcName.size(), TaskGroup::TaskGroupConstructor, nullptr, &cb); in GeneratorTaskGroupWithName()
205 napi_create_function(env, funcName.c_str(), funcName.size(), TaskGroup::TaskGroupConstructor, nullptr, &cb); in HWTEST_F()
218 napi_create_function(env, funcName.c_str(), funcName.size(), TaskGroup::TaskGroupConstructor, nullptr, &cb); in HWTEST_F()
229 napi_create_function(env, funcName.c_str(), funcName.size(), TaskGroup::AddTask, nullptr, &cb); in HWTEST_F()
381 TaskGroup* group = new TaskGroup(); in HWTEST_F()
396 TaskGroup* group = new TaskGroup(); in HWTEST_F()
398 TaskGroup* taskGrou in HWTEST_F()
[all...] |
| H A D | test.cpp | 146 TaskGroup::TaskGroupDestructor(env, data, hint);
in TaskGroupDestructor()
608 TaskGroup* group = new TaskGroup();
in CheckTask()
651 TaskGroup* group = new TaskGroup();
in CancelGroupTask()
714 TaskGroup* group = new TaskGroup();
in UpdateGroupState()
801 TaskGroup* group = new TaskGroup();
in PerformTask()
|
Completed in 13 milliseconds