Home
last modified time | relevance | path

Searched refs:seqRunner (Results 1 – 8 of 8) sorted by relevance

/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A Dsequence_runner.cpp33 uint64_t seqRunnerId = reinterpret_cast<uint64_t>(seqRunner); in SeqRunnerConstructorInner()
44 seqRunner->seqRunnerId_ = seqRunnerId; in SeqRunnerConstructorInner()
48 SequenceRunnerDestructor(env, seqRunner, nullptr); in SeqRunnerConstructorInner()
93 SequenceRunner* seqRunner = nullptr; in SeqRunnerConstructor() local
96 if (seqRunner == nullptr) { in SeqRunnerConstructor()
101 seqRunner = new SequenceRunner(); in SeqRunnerConstructor()
135 if (seqRunner == nullptr) { in Execute()
155 if (seqRunner->currentTaskId_ == 0) { in Execute()
158 seqRunner->currentTaskId_ = task->taskId_; in Execute()
178 if (seqRunner->isGlobalRunner_) {
[all …]
H A Dtask_manager.cpp1646 if (seqRunner == nullptr) { in TriggerSeqRunner()
1666 seqRunner->seqRunnerTasks_.pop(); in TriggerSeqRunner()
1750 SequenceRunner *seqRunner = nullptr; in CreateOrGetGlobalRunner() local
1759 seqRunner->seqName_ = name; in CreateOrGetGlobalRunner()
1762 seqRunner = iter->second; in CreateOrGetGlobalRunner()
1768 seqRunner->count_++; in CreateOrGetGlobalRunner()
1776 return seqRunner; in CreateOrGetGlobalRunner()
1781 if (seqRunner->isGlobalRunner_) { in TriggerGlobalSeqRunner()
1797 return --(seqRunner->count_); in DecreaseSeqCount()
1825 delete seqRunner; in GlobalSequenceRunnerDestructor()
[all …]
H A Dtask_manager.h267 void StoreSequenceRunner(uint64_t seqRunnerId, SequenceRunner* seqRunner);
295 uint64_t DecreaseSeqCount(SequenceRunner* seqRunner);
296 void RemoveGlobalSeqRunnerRef(napi_env env, SequenceRunner* seqRunner);
298 bool TriggerGlobalSeqRunner(napi_env env, SequenceRunner* seqRunner);
299 void GlobalSequenceRunnerDestructor(napi_env env, SequenceRunner *seqRunner);
300 bool IncreaseGlobalSeqRunner(napi_env env, SequenceRunner* seqRunner);
H A Dsequence_runner.h41 …tatic bool SeqRunnerConstructorInner(napi_env env, napi_value &thisVar, SequenceRunner *seqRunner);
/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
H A Dtest.cpp682 seqRunner->priority_ = Priority::DEFAULT; in TriggerSeqRunner()
685 seqRunner->isGlobalRunner_ = true; in TriggerSeqRunner()
691 seqRunner->isGlobalRunner_ = false; in TriggerSeqRunner()
693 seqRunner->currentTaskId_ = task->taskId_; in TriggerSeqRunner()
697 seqRunner->seqRunnerTasks_.push(task1); in TriggerSeqRunner()
700 seqRunner->currentTaskId_ = task->taskId_; in TriggerSeqRunner()
705 seqRunner->seqRunnerTasks_.push(task1); in TriggerSeqRunner()
706 seqRunner->seqRunnerTasks_.push(task); in TriggerSeqRunner()
708 seqRunner->currentTaskId_ = task->taskId_; in TriggerSeqRunner()
729 seqRunner->priority_ = Priority::MEDIUM; in UpdateGroupState()
[all …]
H A Dtest_taskpool.cpp1996 SequenceRunner* seqRunner = new SequenceRunner(); variable
1997 seqRunner->seqRunnerId_ = reinterpret_cast<uint64_t>(seqRunner);
1998 seqRunner->seqName_ = "seq01";
1999 void* data = static_cast<void*>(seqRunner);
4661 SequenceRunner* seqRunner = nullptr; variable
4662 napi_unwrap(env, thisValue, reinterpret_cast<void**>(&seqRunner));
4663 SequenceRunnerManager::GetInstance().RemoveGlobalSeqRunnerRef(env, seqRunner);
/ohos5.0/docs/zh-cn/application-dev/reference/apis-arkts/
H A Djs-apis-taskpool.md2158 async function seqRunner()
/ohos5.0/docs/en/application-dev/reference/apis-arkts/
H A Djs-apis-taskpool.md2162 async function seqRunner()