385     auto taskGroup = TaskGroupManager::GetInstance().GetTaskGroup(groupId);  in ExecuteGroup()  local
386     napi_reference_ref(env, taskGroup->groupRef_, nullptr);  in ExecuteGroup()
387 …if (taskGroup->groupState_ == ExecuteState::NOT_FOUND || taskGroup->groupState_ == ExecuteState::F…  in ExecuteGroup()
388         taskGroup->groupState_ == ExecuteState::CANCELED) {  in ExecuteGroup()
389         taskGroup->groupState_ = ExecuteState::WAITING;  in ExecuteGroup()
394     napi_create_array_with_length(env, taskGroup->taskIds_.size(), &resArr);  in ExecuteGroup()
399         std::lock_guard<RECURSIVE_MUTEX> lock(taskGroup->taskGroupMutex_);  in ExecuteGroup()
400         if (taskGroup->taskNum_ == 0) {  in ExecuteGroup()
402             taskGroup->groupState_ = ExecuteState::FINISHED;  in ExecuteGroup()
404             napi_reference_unref(env, taskGroup->groupRef_, nullptr);  in ExecuteGroup()
406             taskGroup->currentGroupInfo_ = nullptr;  in ExecuteGroup()
409         if (taskGroup->currentGroupInfo_ == nullptr) {  in ExecuteGroup()
410             taskGroup->currentGroupInfo_ = groupInfo;  in ExecuteGroup()
411 …       for (auto iter = taskGroup->taskRefs_.begin(); iter != taskGroup->taskRefs_.end(); iter++) {  in ExecuteGroup()
426             taskGroup->pendingGroupInfos_.push_back(groupInfo);  in ExecuteGroup()
543     TaskGroup* taskGroup = TaskGroupManager::GetInstance().GetTaskGroup(task->groupId_);  in UpdateGroupInfoByResult()  local
544     if (taskGroup == nullptr || taskGroup->currentGroupInfo_ == nullptr) {  in UpdateGroupInfoByResult()
549     uint32_t index = taskGroup->GetTaskIndex(task->taskId_);  in UpdateGroupInfoByResult()
550     auto groupInfo = taskGroup->currentGroupInfo_;  in UpdateGroupInfoByResult()
560     if (groupInfo->finishedTaskNum < taskGroup->taskNum_) {  in UpdateGroupInfoByResult()
567         for (uint64_t taskId : taskGroup->taskIds_) {  in UpdateGroupInfoByResult()
577         auto iter = taskGroup->taskIds_.begin();  in UpdateGroupInfoByResult()
579 …auto task = iter != taskGroup->taskIds_.end() ? TaskManager::GetInstance().GetTask(*iter) : nullpt…  in UpdateGroupInfoByResult()
585     taskGroup->groupState_ = ExecuteState::FINISHED;  in UpdateGroupInfoByResult()
587     napi_reference_unref(env, taskGroup->groupRef_, nullptr);  in UpdateGroupInfoByResult()
589     taskGroup->currentGroupInfo_ = nullptr;  in UpdateGroupInfoByResult()
590     taskGroup->NotifyGroupTask(env);  in UpdateGroupInfoByResult()