Lines Matching refs:task
117 errMessage = "seqRunner:: first param must be task.";
119 ErrorHelper::ThrowError(env, ErrorHelper::TYPE_ERROR, "the type of the first param must be task.");
128 Task* task = nullptr;
129 napi_unwrap(env, args[0], reinterpret_cast<void**>(&task));
130 if (task == nullptr) {
131 ErrorHelper::ThrowError(env, ErrorHelper::TYPE_ERROR, "the type of param must be task.");
134 if (!task->CanForSequenceRunner(env)) {
137 task->seqRunnerId_ = seqRunnerId;
138 napi_value promise = task->GetTaskInfoPromise(env, args[0], TaskType::SEQRUNNER_TASK, seqRunner->priority_);
145 std::to_string(task->taskId_).c_str(), std::to_string(seqRunnerId).c_str());
146 seqRunner->currentTaskId_ = task->taskId_;
147 task->IncreaseRefCount();
148 task->taskState_ = ExecuteState::WAITING;
149 ExecuteTaskImmediately(task->taskId_, seqRunner->priority_);
152 std::to_string(task->taskId_).c_str(), std::to_string(seqRunnerId).c_str());
153 TaskGroupManager::GetInstance().AddTaskToSeqRunner(seqRunnerId, task);