Searched refs:taskGroup (Results 1 - 7 of 7) sorted by relevance
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| H A D | taskpool.cpp | 368 auto taskGroup = TaskGroupManager::GetInstance().GetTaskGroup(groupId);
in ExecuteGroup() local
369 napi_reference_ref(env, taskGroup->groupRef_, nullptr);
in ExecuteGroup()
370 if (taskGroup->groupState_ == ExecuteState::NOT_FOUND || taskGroup->groupState_ == ExecuteState::FINISHED ||
in ExecuteGroup()
371 taskGroup->groupState_ == ExecuteState::CANCELED) {
in ExecuteGroup()
372 taskGroup->groupState_ = ExecuteState::WAITING;
in ExecuteGroup()
377 napi_create_array_with_length(env, taskGroup->taskIds_.size(), &resArr);
in ExecuteGroup()
382 std::lock_guard<RECURSIVE_MUTEX> lock(taskGroup->taskGroupMutex_);
in ExecuteGroup()
383 if (taskGroup->currentGroupInfo_ == nullptr) {
in ExecuteGroup()
384 taskGroup in ExecuteGroup()
515 TaskGroup* taskGroup = TaskGroupManager::GetInstance().GetTaskGroup(task->groupId_); UpdateGroupInfoByResult() local
[all...] |
| H A D | task_manager.cpp | 1471 HILOG_DEBUG("taskpool:: taskGroup has been released"); in AddTask()
1474 auto taskGroup = reinterpret_cast<TaskGroup*>(groupIter->second); in AddTask() local
1475 if (taskGroup == nullptr) { in AddTask()
1476 HILOG_ERROR("taskpool:: taskGroup is null"); in AddTask()
1479 taskGroup->taskRefs_.push_back(taskRef); in AddTask()
1480 taskGroup->taskNum_++; in AddTask()
1481 taskGroup->taskIds_.push_back(taskId); in AddTask()
1508 TaskGroup* taskGroup = GetTaskGroup(groupId); in CancelGroup() local
1509 if (taskGroup == nullptr) { in CancelGroup()
1513 if (taskGroup in CancelGroup()
1657 StoreTaskGroup(uint64_t groupId, TaskGroup* taskGroup) StoreTaskGroup() argument
[all...] |
| H A D | taskpool.h | 62 static napi_value ExecuteGroup(napi_env env, napi_value taskGroup, Priority priority);
|
| H A D | task_manager.h | 252 void StoreTaskGroup(uint64_t groupId, TaskGroup* taskGroup);
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
| H A D | test_taskpool.cpp | 398 TaskGroup* taskGroup = taskGroupManager.GetTaskGroup(groupId); in HWTEST_F() local
399 ASSERT_TRUE(taskGroup == nullptr); in HWTEST_F()
459 TaskGroup taskGroup; in HWTEST_F() local
461 uint32_t index = taskGroup.GetTaskIndex(taskId); in HWTEST_F()
468 TaskGroup taskGroup; in HWTEST_F() local
469 taskGroup.NotifyGroupTask(env); in HWTEST_F()
479 TaskGroup taskGroup; in HWTEST_F() local
480 taskGroup.CancelPendingGroup(env); in HWTEST_F()
868 TaskGroup taskGroup; in HWTEST_F() local
870 taskGroup in HWTEST_F()
878 TaskGroup taskGroup; HWTEST_F() local
888 TaskGroup taskGroup; HWTEST_F() local
901 TaskGroup* taskGroup = new TaskGroup(); HWTEST_F() local
917 TaskGroup* taskGroup = new TaskGroup(); HWTEST_F() local
950 TaskGroup taskGroup; HWTEST_F() local
2011 TaskGroup* taskGroup = new TaskGroup(); HWTEST_F() local
2708 TaskGroup* taskGroup = new TaskGroup(); HWTEST_F() local
2741 TaskGroup* taskGroup = new TaskGroup(); HWTEST_F() local
4582 napi_value taskGroup = GeneratorTaskGroup(env, thisVar); HWTEST_F() local
[all...] |
| H A D | test.h | 43 static napi_value ExecuteGroup(napi_env env, napi_value taskGroup);
|
| H A D | test.cpp | 165 napi_value NativeEngineTest::ExecuteGroup(napi_env env, napi_value taskGroup)
in ExecuteGroup() argument
167 return TaskPool::ExecuteGroup(env, taskGroup, Priority::DEFAULT);
in ExecuteGroup()
|
Completed in 13 milliseconds