Lines Matching refs:task
99 Task* task = nullptr;
100 napi_unwrap(env, args[0], reinterpret_cast<void**>(&task));
101 if (task == nullptr) {
102 ErrorHelper::ThrowError(env, ErrorHelper::TYPE_ERROR, "the type of the params must be task.");
105 if (!task->CanForTaskGroup(env)) {
108 task->taskType_ = TaskType::GROUP_COMMON_TASK;
109 task->groupId_ = groupId;
110 napi_reference_ref(env, task->taskRef_, nullptr);
111 TaskGroupManager::GetInstance().AddTask(groupId, task->taskRef_, task->taskId_);
115 Task* task = Task::GenerateFunctionTask(env, args[0], args + 1, argc - 1, TaskType::GROUP_FUNCTION_TASK);
116 if (task == nullptr) {
119 task->groupId_ = groupId;
120 TaskManager::GetInstance().StoreTask(task->taskId_, task);
121 napi_wrap(env, napiTask, task, Task::TaskDestructor, nullptr, nullptr);
122 napi_create_reference(env, napiTask, 1, &task->taskRef_);
123 TaskGroupManager::GetInstance().AddTask(groupId, task->taskRef_, task->taskId_);
154 Task* task = nullptr;
155 napi_unwrap(env, napiTask, reinterpret_cast<void**>(&task));
156 if (task == nullptr) {
157 HILOG_ERROR("taskpool::ExecuteGroup task is nullptr");
160 napi_reference_ref(env, task->taskRef_, nullptr);
162 if (task->IsGroupCommonTask()) {
163 task->GetTaskInfo(env, napiTask, priority);
167 task->IncreaseRefCount();
168 TaskManager::GetInstance().IncreaseRefCount(task->taskId_);
169 task->taskState_ = ExecuteState::WAITING;
170 TaskManager::GetInstance().EnqueueTaskId(task->taskId_, priority);