Lines Matching refs:seqRunner
30 void SequenceRunner::SeqRunnerConstructorInner(napi_env env, napi_value &thisVar, SequenceRunner *seqRunner)
32 // update seqRunner.seqRunnerId
33 uint64_t seqRunnerId = reinterpret_cast<uint64_t>(seqRunner);
35 TaskGroupManager::GetInstance().StoreSequenceRunner(seqRunnerId, seqRunner);
41 HILOG_INFO("taskpool:: construct seqRunner name is %{public}s, seqRunnerid %{public}s.",
42 seqRunner->seqName_.c_str(), std::to_string(seqRunnerId).c_str());
44 seqRunner->seqRunnerId_ = seqRunnerId;
45 napi_wrap(env, thisVar, seqRunner, SequenceRunnerDestructor, nullptr, nullptr);
58 if (argc == 2) { // 2: The number of parameters is 2, if the first is seqRunner name, the second must be priority
86 SequenceRunner* seqRunner = nullptr;
88 seqRunner = SequenceRunnerManager::GetInstance().CreateOrGetGlobalRunner(env, thisVar, argc, name, priority);
89 if (seqRunner == nullptr) {
94 seqRunner = new SequenceRunner();
95 seqRunner->priority_ = static_cast<Priority>(priority);
96 napi_create_reference(env, thisVar, 0, &seqRunner->seqRunnerRef_);
99 SeqRunnerConstructorInner(env, thisVar, seqRunner);
111 errMessage = "seqRunner:: number of params at least one";
117 errMessage = "seqRunner:: first param must be task.";
124 SequenceRunner* seqRunner = TaskGroupManager::GetInstance().GetSeqRunner(seqRunnerId);
125 if (seqRunner == nullptr) {
138 napi_value promise = task->GetTaskInfoPromise(env, args[0], TaskType::SEQRUNNER_TASK, seqRunner->priority_);
142 napi_reference_ref(env, seqRunner->seqRunnerRef_, nullptr);
143 if (seqRunner->currentTaskId_ == 0) {
144 HILOG_INFO("taskpool:: taskId %{public}s in seqRunner %{public}s immediately.",
146 seqRunner->currentTaskId_ = task->taskId_;
149 ExecuteTaskImmediately(task->taskId_, seqRunner->priority_);
151 HILOG_INFO("taskpool:: add taskId: %{public}s to seqRunner %{public}s.",
165 SequenceRunner* seqRunner = static_cast<SequenceRunner*>(data);
166 if (seqRunner->isGlobalRunner_) {
167 SequenceRunnerManager::GetInstance().GlobalSequenceRunnerDestructor(env, seqRunner);
169 TaskGroupManager::GetInstance().RemoveSequenceRunner(seqRunner->seqRunnerId_);
170 napi_delete_reference(env, seqRunner->seqRunnerRef_);
171 delete seqRunner;