Lines Matching refs:taskGroup
368 auto taskGroup = TaskGroupManager::GetInstance().GetTaskGroup(groupId);
369 napi_reference_ref(env, taskGroup->groupRef_, nullptr);
370 if (taskGroup->groupState_ == ExecuteState::NOT_FOUND || taskGroup->groupState_ == ExecuteState::FINISHED ||
371 taskGroup->groupState_ == ExecuteState::CANCELED) {
372 taskGroup->groupState_ = ExecuteState::WAITING;
377 napi_create_array_with_length(env, taskGroup->taskIds_.size(), &resArr);
382 std::lock_guard<RECURSIVE_MUTEX> lock(taskGroup->taskGroupMutex_);
383 if (taskGroup->currentGroupInfo_ == nullptr) {
384 taskGroup->currentGroupInfo_ = groupInfo;
385 for (auto iter = taskGroup->taskRefs_.begin(); iter != taskGroup->taskRefs_.end(); iter++) {
400 taskGroup->pendingGroupInfos_.push_back(groupInfo);
515 TaskGroup* taskGroup = TaskGroupManager::GetInstance().GetTaskGroup(task->groupId_);
516 if (taskGroup == nullptr) {
517 HILOG_DEBUG("taskpool:: taskGroup has been released");
520 if (taskGroup->currentGroupInfo_ == nullptr) {
521 HILOG_DEBUG("taskpool:: taskGroup has been canceled");
524 uint32_t index = taskGroup->GetTaskIndex(task->taskId_);
525 auto groupInfo = taskGroup->currentGroupInfo_;
533 if (groupInfo->finishedTask < taskGroup->taskNum_) {
536 HILOG_INFO("taskpool:: taskGroup perform end, taskGroupId %{public}s", std::to_string(task->groupId_).c_str());
538 for (uint64_t taskId : taskGroup->taskIds_) {
551 taskGroup->groupState_ = ExecuteState::FINISHED;
553 napi_reference_unref(env, taskGroup->groupRef_, nullptr);
555 taskGroup->currentGroupInfo_ = nullptr;
556 taskGroup->NotifyGroupTask(env);
603 ErrorHelper::ThrowError(env, ErrorHelper::TYPE_ERROR, "the type of the params must be taskGroup.");