45 TaskManager& TaskManager::GetInstance()  in GetInstance()
47     static TaskManager manager;  in GetInstance()
51 TaskManager::TaskManager()  in TaskManager()  function in Commonlibrary::Concurrent::TaskPoolModule::TaskManager
59 TaskManager::~TaskManager()  in ~TaskManager()
92 void TaskManager::CountTraceForWorker()  in CountTraceForWorker()
104 napi_value TaskManager::GetThreadInfos(napi_env env)  in GetThreadInfos()
143 napi_value TaskManager::GetTaskInfos(napi_env env)  in GetTaskInfos()
182 void TaskManager::UpdateExecutedInfo(uint64_t duration)  in UpdateExecutedInfo()
188 uint32_t TaskManager::ComputeSuitableThreadNum()  in ComputeSuitableThreadNum()
206 void TaskManager::CheckForBlockedWorkers()  in CheckForBlockedWorkers()
251 void TaskManager::TryTriggerExpand()  in TryTriggerExpand()
264 bool TaskManager::ReadThreadInfo(Worker* worker, char* buf, uint32_t size)  in ReadThreadInfo()
289 uint32_t TaskManager::GetIdleWorkers()  in GetIdleWorkers()
310 void TaskManager::GetIdleWorkersList(uint32_t step)  in GetIdleWorkersList()
335 void TaskManager::TriggerShrink(uint32_t step)  in TriggerShrink()
359 uint32_t TaskManager::GetIdleWorkers()  in GetIdleWorkers()
365 void TaskManager::TriggerShrink(uint32_t step)  in TriggerShrink()
384 void TaskManager::NotifyShrink(uint32_t targetNum)  in NotifyShrink()
408 void TaskManager::TriggerLoadBalance(const uv_timer_t* req)  in TriggerLoadBalance()
410     TaskManager& taskManager = TaskManager::GetInstance();  in TriggerLoadBalance()
422 void TaskManager::TryExpand()  in TryExpand()
450 void TaskManager::NotifyExpand(const uv_async_t* req)  in NotifyExpand()
452     TaskManager& taskManager = TaskManager::GetInstance();  in NotifyExpand()
456 void TaskManager::RunTaskManager()  in RunTaskManager()
462 …uv_timer_start(timer_, reinterpret_cast<uv_timer_cb>(TaskManager::TriggerLoadBalance), 0, 60000); …  in RunTaskManager()
463     uv_async_init(loop_, expandHandle_, reinterpret_cast<uv_async_cb>(TaskManager::NotifyExpand));  in RunTaskManager()
477 void TaskManager::CancelTask(napi_env env, uint64_t taskId)  in CancelTask()
512 void TaskManager::NotifyWorkerIdle(Worker* worker)  in NotifyWorkerIdle()
527 void TaskManager::NotifyWorkerCreated(Worker* worker)  in NotifyWorkerCreated()
537 void TaskManager::NotifyWorkerAdded(Worker* worker)  in NotifyWorkerAdded()
544 void TaskManager::NotifyWorkerRunning(Worker* worker)  in NotifyWorkerRunning()
551 uint32_t TaskManager::GetRunningWorkers()  in GetRunningWorkers()
559 uint32_t TaskManager::GetTimeoutWorkers()  in GetTimeoutWorkers()
565 uint32_t TaskManager::GetTaskNum()  in GetTaskNum()
572 uint32_t TaskManager::GetThreadNum()  in GetThreadNum()
578 void TaskManager::EnqueueTaskId(uint64_t taskId, Priority priority)  in EnqueueTaskId()
587 std::pair<uint64_t, Priority> TaskManager::DequeueTaskId()  in DequeueTaskId()
624 void TaskManager::NotifyExecuteTask()  in NotifyExecuteTask()
632 void TaskManager::InitTaskManager(napi_env env)  in InitTaskManager()
644         std::thread workerManager(&TaskManager::RunTaskManager, this);  in InitTaskManager()
649 void TaskManager::CreateWorkers(napi_env env, uint32_t num)  in CreateWorkers()
659 void TaskManager::RemoveWorker(Worker* worker)  in RemoveWorker()
666 void TaskManager::RestoreWorker(Worker* worker)  in RestoreWorker()
687 void TaskManager::RegisterCallback(napi_env env, uint64_t taskId, std::shared_ptr<CallbackInfo> cal…  in RegisterCallback()
693 std::shared_ptr<CallbackInfo> TaskManager::GetCallbackInfo(uint64_t taskId)  in GetCallbackInfo()
704 void TaskManager::IncreaseRefCount(uint64_t taskId)  in IncreaseRefCount()
717 void TaskManager::DecreaseRefCount(napi_env env, uint64_t taskId)  in DecreaseRefCount()
733 napi_value TaskManager::NotifyCallbackExecute(napi_env env, TaskResultInfo* resultInfo, Task* task)  in NotifyCallbackExecute()
752 void TaskManager::NotifyDependencyTaskInfo(uint64_t taskId)  in NotifyDependencyTaskInfo()
785 bool TaskManager::IsDependendByTaskId(uint64_t taskId)  in IsDependendByTaskId()
806 bool TaskManager::StoreTaskDependency(uint64_t taskId, std::set<uint64_t> taskIdSet)  in StoreTaskDependency()
838 bool TaskManager::CheckCircularDependency(std::set<uint64_t> dependentIdSet, std::set<uint64_t> idS…  in CheckCircularDependency()
859 bool TaskManager::RemoveTaskDependency(uint64_t taskId, uint64_t dependentId)  in RemoveTaskDependency()
875 void TaskManager::EnqueuePendingTaskInfo(uint64_t taskId, Priority priority)  in EnqueuePendingTaskInfo()
884 std::pair<uint64_t, Priority> TaskManager::DequeuePendingTaskInfo(uint64_t taskId)  in DequeuePendingTaskInfo()
901 void TaskManager::RemovePendingTaskInfo(uint64_t taskId)  in RemovePendingTaskInfo()
907 void TaskManager::StoreDependentTaskInfo(std::set<uint64_t> dependentTaskIdSet, uint64_t taskId)  in StoreDependentTaskInfo()
920 void TaskManager::RemoveDependentTaskInfo(uint64_t dependentTaskId, uint64_t taskId)  in RemoveDependentTaskInfo()
933 void TaskManager::StoreTaskDuration(uint64_t taskId, uint64_t totalDuration, uint64_t cpuDuration)  in StoreTaskDuration()
950 uint64_t TaskManager::GetTaskDuration(uint64_t taskId, std::string durationType)  in GetTaskDuration()
967 void TaskManager::RemoveTaskDuration(uint64_t taskId)  in RemoveTaskDuration()
976 void TaskManager::ReleaseTaskData(napi_env env, Task* task)  in ReleaseTaskData()
1003 void TaskManager::StoreTask(uint64_t taskId, Task* task)  in StoreTask()
1009 void TaskManager::RemoveTask(uint64_t taskId)  in RemoveTask()
1015 Task* TaskManager::GetTask(uint64_t taskId)  in GetTask()
1048         Task* task = TaskManager::GetInstance().GetTask(taskId);  in ReleaseTaskGroupData()
1090     auto task = TaskManager::GetInstance().GetTask(taskId);  in CancelGroupTask()
1189         TaskManager::GetInstance().EnqueueTaskId(task->taskId_, seqRunner->priority_);  in TriggerSeqRunner()
1190         TaskManager::GetInstance().TryTriggerExpand();  in TriggerSeqRunner()