44 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()
281 void TaskManager::TriggerLoadBalance(const uv_timer_t* req)  in TriggerLoadBalance()
286     TaskManager& taskManager = TaskManager::GetInstance();  in TriggerLoadBalance()
313 void TaskManager::RestartTimer(const uv_async_t* req)  in RestartTimer()
315     TaskManager& taskManager = TaskManager::GetInstance();  in RestartTimer()
319 void TaskManager::RunTaskManager()  in RunTaskManager()
325 …uv_timer_start(timer_, reinterpret_cast<uv_timer_cb>(TaskManager::TriggerLoadBalance), 0, 1000); /…  in RunTaskManager()
326 …uv_async_init(loop_, notifyRestartTimer_, reinterpret_cast<uv_async_cb>(TaskManager::RestartTimer)…  in RunTaskManager()
336 uint32_t TaskManager::GenerateTaskId()  in GenerateTaskId()
341 uint32_t TaskManager::GenerateExecuteId()  in GenerateExecuteId()
346 void TaskManager::StoreTaskEnvInfo(napi_env env)  in StoreTaskEnvInfo()
357 void TaskManager::PopTaskEnvInfo(napi_env env)  in PopTaskEnvInfo()
368 bool TaskManager::HasTaskEnvInfo(napi_env env)  in HasTaskEnvInfo()
374 void TaskManager::StoreTaskInfo(uint32_t executeId, TaskInfo* taskInfo)  in StoreTaskInfo()
380 void TaskManager::StoreRunningInfo(uint32_t taskId, uint32_t executeId)  in StoreRunningInfo()
392 TaskInfo* TaskManager::PopTaskInfo(uint32_t executeId)  in PopTaskInfo()
406 TaskInfo* TaskManager::GetTaskInfo(uint32_t executeId)  in GetTaskInfo()
416 bool TaskManager::MarkCanceledState(uint32_t executeId)  in MarkCanceledState()
430 void TaskManager::PopRunningInfo(uint32_t taskId, uint32_t executeId)  in PopRunningInfo()
440 void TaskManager::AddExecuteState(uint32_t executeId)  in AddExecuteState()
446 bool TaskManager::UpdateExecuteState(uint32_t executeId, ExecuteState state)  in UpdateExecuteState()
460 void TaskManager::RemoveExecuteState(uint32_t executeId)  in RemoveExecuteState()
466 ExecuteState TaskManager::QueryExecuteState(uint32_t executeId)  in QueryExecuteState()
477 void TaskManager::CancelTask(napi_env env, uint32_t taskId)  in CancelTask()
492 void TaskManager::CancelExecution(napi_env env, uint32_t executeId)  in CancelExecution()
527 TaskInfo* TaskManager::GenerateTaskInfo(napi_env env, napi_value func, napi_value args,  in GenerateTaskInfo()
563 TaskInfo* TaskManager::GenerateTaskInfoFromTask(napi_env env, napi_value task, uint32_t executeId)  in GenerateTaskInfoFromTask()
578 void TaskManager::ReleaseTaskContent(TaskInfo* taskInfo)  in ReleaseTaskContent()
594 void TaskManager::NotifyWorkerIdle(Worker* worker)  in NotifyWorkerIdle()
605 void TaskManager::NotifyWorkerCreated(Worker* worker)  in NotifyWorkerCreated()
611 void TaskManager::NotifyWorkerAdded(Worker* worker)  in NotifyWorkerAdded()
617 void TaskManager::TryTriggerLoadBalance()  in TryTriggerLoadBalance()
625 uint32_t TaskManager::GetIdleWorkers()  in GetIdleWorkers()
631 uint32_t TaskManager::GetRunningWorkers()  in GetRunningWorkers()
639 uint32_t TaskManager::GetTimeoutWorkers()  in GetTimeoutWorkers()
645 uint32_t TaskManager::GetTaskNum()  in GetTaskNum()
652 uint32_t TaskManager::GetThreadNum()  in GetThreadNum()
658 void TaskManager::EnqueueExecuteId(uint32_t executeId, Priority priority)  in EnqueueExecuteId()
675 std::pair<uint32_t, Priority> TaskManager::DequeueExecuteId()  in DequeueExecuteId()
696 void TaskManager::NotifyExecuteTask()  in NotifyExecuteTask()
708 void TaskManager::InitTaskManager(napi_env env)  in InitTaskManager()
720         std::thread workerManager(&TaskManager::RunTaskManager, this);  in InitTaskManager()
725 void TaskManager::CreateWorkers(napi_env env, uint32_t num)  in CreateWorkers()
734 void TaskManager::RemoveWorker(Worker* worker)  in RemoveWorker()
741 napi_value TaskManager::IsCanceled(napi_env env, napi_callback_info cbinfo)  in IsCanceled()
939     ExecuteState state = TaskManager::GetInstance().QueryExecuteState(executeId);  in CancelGroupExecution()
945             TaskManager::GetInstance().MarkCanceledState(executeId);  in CancelGroupExecution()
949             taskInfo = TaskManager::GetInstance().PopTaskInfo(executeId);  in CancelGroupExecution()
954             TaskManager::GetInstance().RemoveExecuteState(executeId);  in CancelGroupExecution()
955             TaskManager::GetInstance().ReleaseTaskContent(taskInfo);  in CancelGroupExecution()