Home
last modified time | relevance | path

Searched refs:SequenceRunner (Results 1 - 7 of 7) sorted by relevance

/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A Dsequence_runner.h25 class SequenceRunner { class
27 SequenceRunner() = default;
28 ~SequenceRunner() = default;
34 SequenceRunner(const SequenceRunner &) = delete;
35 SequenceRunner& operator=(const SequenceRunner &) = delete;
36 SequenceRunner(SequenceRunner &&) = delete;
37 SequenceRunner
[all...]
H A Dsequence_runner.cpp30 void SequenceRunner::SeqRunnerConstructorInner(napi_env env, napi_value &thisVar, SequenceRunner *seqRunner) in SeqRunnerConstructorInner()
48 napi_value SequenceRunner::SeqRunnerConstructor(napi_env env, napi_callback_info cbinfo) in SeqRunnerConstructor()
86 SequenceRunner* seqRunner = nullptr; in SeqRunnerConstructor()
94 seqRunner = new SequenceRunner(); in SeqRunnerConstructor()
103 napi_value SequenceRunner::Execute(napi_env env, napi_callback_info cbinfo) in Execute()
124 SequenceRunner* seqRunner = TaskGroupManager::GetInstance().GetSeqRunner(seqRunnerId); in Execute()
158 void SequenceRunner::ExecuteTaskImmediately(uint64_t taskId, Priority priority) in ExecuteTaskImmediately()
163 void SequenceRunner::SequenceRunnerDestructor(napi_env env, void* data, [[maybe_unused]] void* hint) in SequenceRunnerDestructor()
165 SequenceRunner* seqRunne in SequenceRunnerDestructor()
[all...]
H A Dtask_manager.h263 void StoreSequenceRunner(uint64_t seqRunnerId, SequenceRunner* seqRunner);
265 SequenceRunner* GetSeqRunner(uint64_t seqRunnerId);
277 // <seqRunnerId, SequenceRunner>
278 std::unordered_map<uint64_t, SequenceRunner*> seqRunners_ {};
289 SequenceRunner* CreateOrGetGlobalRunner(napi_env env, napi_value thisVar, size_t argc,
291 uint64_t DecreaseSeqCount(SequenceRunner* seqRunner);
292 void RemoveGlobalSeqRunnerRef(napi_env env, SequenceRunner* seqRunner);
294 bool TriggerGlobalSeqRunner(napi_env env, SequenceRunner* seqRunner);
295 void GlobalSequenceRunnerDestructor(napi_env env, SequenceRunner *seqRunner);
304 std::unordered_map<std::string, SequenceRunner*> globalSeqRunner
[all...]
H A Dtask_manager.cpp1565 void TaskGroupManager::StoreSequenceRunner(uint64_t seqRunnerId, SequenceRunner* seqRunner) in StoreSequenceRunner()
1577 SequenceRunner* TaskGroupManager::GetSeqRunner(uint64_t seqRunnerId) in GetSeqRunner()
1604 SequenceRunner* seqRunner = GetSeqRunner(seqRunnerId); in TriggerSeqRunner()
1705 SequenceRunner* SequenceRunnerManager::CreateOrGetGlobalRunner(napi_env env, napi_value thisVar, size_t argc, in CreateOrGetGlobalRunner()
1709 SequenceRunner *seqRunner = nullptr; in CreateOrGetGlobalRunner()
1712 seqRunner = new SequenceRunner(); in CreateOrGetGlobalRunner()
1738 bool SequenceRunnerManager::TriggerGlobalSeqRunner(napi_env env, SequenceRunner* seqRunner) in TriggerGlobalSeqRunner()
1753 uint64_t SequenceRunnerManager::DecreaseSeqCount(SequenceRunner* seqRunner) in DecreaseSeqCount()
1759 void SequenceRunnerManager::RemoveGlobalSeqRunnerRef(napi_env env, SequenceRunner* seqRunner) in RemoveGlobalSeqRunnerRef()
1778 void SequenceRunnerManager::GlobalSequenceRunnerDestructor(napi_env env, SequenceRunner *seqRunne
[all...]
H A Dtaskpool.cpp54 napi_define_class(env, "SequenceRunner", NAPI_AUTO_LENGTH, SequenceRunner::SeqRunnerConstructor, in InitTaskPool()
88 DECLARE_NAPI_PROPERTY("SequenceRunner", seqRunnerClass), in InitTaskPool()
/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
H A Dtest.cpp152 SequenceRunner::SequenceRunnerDestructor(env, data, hint); in SequenceRunnerDestructor()
666 SequenceRunner* seqRunner = new SequenceRunner(); in CancelGroupTask()
679 SequenceRunner* seqRunner = new SequenceRunner(); in TriggerSeqRunner()
727 SequenceRunner* seqRunner = runnerManager.CreateOrGetGlobalRunner(env, obj, SIZE_THREE_, "test", UINT32_ONE_); in UpdateGroupState()
H A Dtest_taskpool.cpp430 napi_create_function(env, funcName.c_str(), funcName.size(), SequenceRunner::SeqRunnerConstructor, nullptr, &cb); in HWTEST_F()
443 napi_create_function(env, func.c_str(), func.size(), SequenceRunner::SeqRunnerConstructor, nullptr, &callback); in HWTEST_F()
452 napi_create_function(env, func.c_str(), func.size(), SequenceRunner::Execute, nullptr, &callback); in HWTEST_F()
792 SequenceRunner sequenceRunner; in HWTEST_F()
796 SequenceRunner *res = taskGroupManager.GetSeqRunner(seqRunnerId); in HWTEST_F()
1164 napi_create_function(env, func.c_str(), func.size(), SequenceRunner::SeqRunnerConstructor, nullptr, &callback); in HWTEST_F()
1194 napi_create_function(env, func.c_str(), func.size(), SequenceRunner::SeqRunnerConstructor, nullptr, &callback); in HWTEST_F()
1206 napi_create_function(env, func.c_str(), func.size(), SequenceRunner::Execute, nullptr, &cb); in HWTEST_F()
1225 SequenceRunner seq; in HWTEST_F()
1990 SequenceRunner* seqRunne in HWTEST_F()
[all...]

Completed in 15 milliseconds