Home
last modified time | relevance | path

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

/commonlibrary/ets_utils/js_concurrent_module/taskpool/
Dtask_manager.cpp44 TaskManager& TaskManager::GetInstance() in GetInstance()
46 static TaskManager manager; in GetInstance()
50 TaskManager::TaskManager() in TaskManager() function in Commonlibrary::Concurrent::TaskPoolModule::TaskManager
58 TaskManager::~TaskManager() in ~TaskManager()
100 napi_value TaskManager::GetThreadInfos(napi_env env) in GetThreadInfos()
141 napi_value TaskManager::GetTaskInfos(napi_env env) in GetTaskInfos()
178 void TaskManager::UpdateExecutedInfo(uint64_t duration) in UpdateExecutedInfo()
184 uint32_t TaskManager::ComputeSuitableThreadNum() in ComputeSuitableThreadNum()
197 void TaskManager::CheckForBlockedWorkers() in CheckForBlockedWorkers()
231 void TaskManager::CreateOrDeleteWorkers(uint32_t targetNum) in CreateOrDeleteWorkers()
[all …]
Dtask_manager.h42 class TaskManager {
44 TaskManager();
45 ~TaskManager();
47 static TaskManager& GetInstance();
93 TaskManager(const TaskManager &) = delete;
94 TaskManager& operator=(const TaskManager &) = delete;
95 TaskManager(TaskManager &&) = delete;
96 TaskManager& operator=(TaskManager &&) = delete;
Dtaskpool.cpp38 …napi_create_function(env, "isCanceled", NAPI_AUTO_LENGTH, TaskManager::IsCanceled, NULL, &isCancel… in InitTaskPool()
63 TaskManager::GetInstance().InitTaskManager(env); in InitTaskPool()
71 napi_value threadInfos = TaskManager::GetInstance().GetThreadInfos(env); in GetTaskPoolInfo()
72 napi_value taskInfos = TaskManager::GetInstance().GetTaskInfos(env); in GetTaskPoolInfo()
112 uint32_t executeId = TaskManager::GetInstance().GenerateExecuteId(); in Execute()
113 … TaskInfo* taskInfo = TaskManager::GetInstance().GenerateTaskInfoFromTask(env, args[0], executeId); in Execute()
119 TaskManager::GetInstance().StoreRunningInfo(taskInfo->taskId, executeId); in Execute()
133 uint32_t executeId = TaskManager::GetInstance().GenerateExecuteId(); in Execute()
135 …TaskInfo* taskInfo = TaskManager::GetInstance().GenerateTaskInfo(env, args[0], argsArray, 0, execu… in Execute()
141 TaskManager::GetInstance().StoreRunningInfo(0, executeId); in Execute()
[all …]
Dworker.cpp164 TaskManager::GetInstance().RemoveWorker(worker); in ExecuteInThread()
225 TaskManager::GetInstance().NotifyWorkerIdle(this); in NotifyIdle()
230 TaskManager::GetInstance().NotifyWorkerCreated(this); in NotifyWorkerCreated()
254 auto executeIdAndPriority = TaskManager::GetInstance().DequeueExecuteId(); in PerformTask()
261 TaskInfo* taskInfo = TaskManager::GetInstance().GetTaskInfo(executeIdAndPriority.first); in PerformTask()
277 TaskManager::GetInstance().UpdateExecuteState(taskInfo->executeId, ExecuteState::RUNNING); in PerformTask()
336 TaskManager::GetInstance().UpdateExecutedInfo(duration); in PerformTask()
363 TaskManager::GetInstance().RemoveExecuteState(taskInfo->executeId); in NotifyTaskResult()
365 TaskManager::GetInstance().PopRunningInfo(taskInfo->taskId, taskInfo->executeId); in NotifyTaskResult()
367 TaskManager::GetInstance().PopTaskInfo(taskInfo->executeId); in NotifyTaskResult()
Dtaskpool.h49 friend class TaskManager; variable
Dtask.cpp58 napi_value taskId = NapiHelper::CreateUint32(env, TaskManager::GetInstance().GenerateTaskId()); in CreateTaskByFunc()
Dworker.h161 friend class TaskManager; variable
/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
Dtest_taskpool.cpp34 TaskManager &taskManager = TaskManager::GetInstance();
49 TaskManager &taskManager = TaskManager::GetInstance();
56 TaskManager &taskManager = TaskManager::GetInstance();
76 uint32_t workers = TaskManager::GetInstance().GetRunningWorkers();
83 TaskManager &taskManager = TaskManager::GetInstance();
91 TaskManager &taskManager = TaskManager::GetInstance();
99 TaskManager &taskManager = TaskManager::GetInstance();
112 TaskManager &taskManager = TaskManager::GetInstance();
120 TaskManager &taskManager = TaskManager::GetInstance();
149 TaskManager& taskManger = TaskManager::GetInstance();
[all …]