Searched refs:TaskPool (Results 1 - 7 of 7) sorted by relevance
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| H A D | taskpool.h | 34 class TaskPool {
class
43 TaskPool() = delete;
44 ~TaskPool() = delete;
45 TaskPool(const TaskPool &) = delete;
46 TaskPool& operator=(const TaskPool &) = delete;
47 TaskPool(TaskPool &&) = delete;
48 TaskPool
[all...] |
| H A D | taskpool.cpp | 32 napi_value TaskPool::InitTaskPool(napi_env env, napi_value exports)
in InitTaskPool()
106 void TaskPool::ExecuteCallback(const uv_async_t* req)
in ExecuteCallback()
116 void TaskPool::ExecuteCallbackTask(CallbackInfo* callbackInfo)
in ExecuteCallbackTask()
126 void TaskPool::ExecuteCallbackInner(MsgQueue& msgQueue)
in ExecuteCallbackInner()
174 napi_value TaskPool::GetTaskPoolInfo(napi_env env, [[maybe_unused]] napi_callback_info cbinfo)
in GetTaskPoolInfo()
185 napi_value TaskPool::TerminateTask(napi_env env, napi_callback_info cbinfo)
in TerminateTask()
210 napi_value TaskPool::Execute(napi_env env, napi_callback_info cbinfo)
in Execute()
272 void TaskPool::DelayTask(uv_timer_t* handle)
in DelayTask()
315 napi_value TaskPool::ExecuteDelayed(napi_env env, napi_callback_info cbinfo)
in ExecuteDelayed()
363 napi_value TaskPool
[all...] |
| H A D | native_module_taskpool.cpp | 25 .nm_register_func = Commonlibrary::Concurrent::TaskPoolModule::TaskPool::InitTaskPool,
|
| H A D | task.cpp | 419 ConcurrentHelper::UvHandleInit(loop, callbackInfo->onCallbackSignal, TaskPool::ExecuteCallback); in OnReceiveData()
423 ConcurrentHelper::UvHandleInit(loop, callbackInfo->onCallbackSignal, TaskPool::ExecuteCallback); in OnReceiveData()
1335 ConcurrentHelper::UvHandleInit(loop, onResultSignal_, TaskPool::HandleTaskResult, this); in InitHandle()
1342 ConcurrentHelper::UvHandleInit(loop, onResultSignal_, TaskPool::HandleTaskResult, this); in InitHandle()
1382 TaskPool::HandleTaskResultCallback(task); in VerifyAndPostResult()
|
| H A D | task_manager.cpp | 984 TaskPool::ExecuteCallbackTask(callbackInfo.get()); in NotifyCallbackExecute()
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
| H A D | test.cpp | 88 napi_create_function(env, funcName.c_str(), funcName.size(), TaskPool::IsConcurrent, nullptr, &cb);
in IsConcurrent()
98 napi_create_function(env, funcName.c_str(), funcName.size(), TaskPool::GetTaskPoolInfo, nullptr, &cb);
in GetTaskPoolInfo()
108 napi_create_function(env, funcName.c_str(), funcName.size(), TaskPool::TerminateTask, nullptr, &cb);
in TerminateTask()
118 napi_create_function(env, funcName.c_str(), funcName.size(), TaskPool::Execute, nullptr, &cb);
in Execute()
128 napi_create_function(env, funcName.c_str(), funcName.size(), TaskPool::ExecuteDelayed, nullptr, &cb);
in ExecuteDelayed()
138 napi_create_function(env, funcName.c_str(), funcName.size(), TaskPool::Cancel, nullptr, &cb);
in Cancel()
160 napi_create_function(env, funcName.c_str(), funcName.size(), TaskPool::ExecutePeriodically, nullptr, &cb);
in ExecutePeriodically()
167 return TaskPool::ExecuteGroup(env, taskGroup, Priority::DEFAULT);
in ExecuteGroup()
172 TaskPool::DelayTask(handle);
in DelayTask()
177 TaskPool in PeriodicTaskCallback()
[all...] |
| H A D | test_taskpool.cpp | 139 napi_value result = TaskPool::InitTaskPool(env, taskClass); in HWTEST_F()
239 napi_value result = TaskPool::InitTaskPool(env, value); in HWTEST_F()
2043 TaskPool::ExecuteCallback(req); in HWTEST_F()
2056 TaskPool::ExecuteCallback(req); in HWTEST_F()
2090 TaskPool::ExecuteCallback(req); in HWTEST_F()
2134 TaskPool::ExecuteCallback(req); in HWTEST_F()
2149 TaskPool::ExecuteCallbackTask(cbInfo); in HWTEST_F()
2157 TaskPool::ExecuteCallbackTask(cbInfo); in HWTEST_F()
4471 TaskPool::HandleTaskResultCallback(task); in HWTEST_F()
4490 TaskPool in HWTEST_F()
[all...] |
Completed in 17 milliseconds