Home
last modified time | relevance | path

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

/commonlibrary/ets_utils/js_concurrent_module/taskpool/
Dtask_manager.cpp45 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()
[all …]
Dtask_manager.h58 class TaskManager {
60 static TaskManager& GetInstance();
124 TaskManager();
125 ~TaskManager();
126 TaskManager(const TaskManager &) = delete;
127 TaskManager& operator=(const TaskManager &) = delete;
128 TaskManager(TaskManager &&) = delete;
129 TaskManager& operator=(TaskManager &&) = delete;
Dworker.cpp54 TaskManager::GetInstance().RemoveWorker(worker); in ReleaseWorkerHandles()
57 TaskManager::GetInstance().GetThreadNum()); in ReleaseWorkerHandles()
91 TaskManager& taskManager = TaskManager::GetInstance(); in CheckFreeConditions()
180 TaskManager::GetInstance().RemoveWorker(worker); in ExecuteInThread()
181 TaskManager::GetInstance().CountTraceForWorker(); in ExecuteInThread()
247 TaskManager::GetInstance().NotifyWorkerIdle(this); in NotifyIdle()
252 TaskManager::GetInstance().NotifyWorkerCreated(this); in NotifyWorkerCreated()
277 TaskManager::GetInstance().NotifyWorkerRunning(worker); in PerformTask()
278 auto taskInfo = TaskManager::GetInstance().DequeueTaskId(); in PerformTask()
285 Task* task = TaskManager::GetInstance().GetTask(taskInfo.first); in PerformTask()
[all …]
Dtaskpool.cpp75 TaskManager::GetInstance().InitTaskManager(env); in InitTaskPool()
92 auto callbackInfo = TaskManager::GetInstance().GetCallbackInfo(resultInfo->taskId); in ExecuteCallback()
122 auto task = TaskManager::GetInstance().GetTask(resultInfo->taskId); in ExecuteCallback()
135 napi_value threadInfos = TaskManager::GetInstance().GetThreadInfos(env); in GetTaskPoolInfo()
136 napi_value taskInfos = TaskManager::GetInstance().GetTaskInfos(env); in GetTaskPoolInfo()
196 TaskManager::GetInstance().StoreTask(task->taskId_, task); in Execute()
205 auto task = TaskManager::GetInstance().GetTask(taskMessage->taskId); in DelayTask()
209 TaskManager::GetInstance().IncreaseRefCount(taskMessage->taskId); in DelayTask()
211 … TaskManager::GetInstance().EnqueueTaskId(taskMessage->taskId, Priority(taskMessage->priority)); in DelayTask()
212 TaskManager::GetInstance().TryTriggerExpand(); in DelayTask()
[all …]
Dtask_group.cpp111 TaskManager::GetInstance().StoreTask(task->taskId_, task); in AddTask()
154 TaskManager::GetInstance().IncreaseRefCount(task->taskId_); in NotifyGroupTask()
156 TaskManager::GetInstance().EnqueueTaskId(task->taskId_, priority); in NotifyGroupTask()
157 TaskManager::GetInstance().TryTriggerExpand(); in NotifyGroupTask()
Dtaskpool.h59 friend class TaskManager; variable
70 TaskManager::GetInstance().DecreaseRefCount(env_, taskId_); in ~CallbackScope()
Dtask.cpp72 TaskManager::GetInstance().StoreTask(task->taskId_, task); in TaskConstructor()
81 TaskManager::GetInstance().ReleaseTaskData(env, task); in TaskDestructor()
357 TaskManager::GetInstance().RegisterCallback(env, taskId, nullptr); in OnReceiveData()
379 TaskManager::GetInstance().RegisterCallback(env, taskId, callbackInfo); in OnReceiveData()
425 return TaskManager::GetInstance().NotifyCallbackExecute(env, resultInfo, task); in SendData()
488 if (!TaskManager::GetInstance().StoreTaskDependency(task->taskId_, idSet)) { in AddDependency()
521 … if (!TaskManager::GetInstance().RemoveTaskDependency(task->taskId_, dependentTask->taskId_)) { in RemoveDependency()
536 uint64_t totalDuration = TaskManager::GetInstance().GetTaskDuration(taskId, durationType); in GetTaskDuration()
644 TaskManager::GetInstance().NotifyDependencyTaskInfo(taskId_); in NotifyPendingTask()
654 TaskManager::GetInstance().EnqueueTaskId(taskId_, currentTaskInfo_->priority); in NotifyPendingTask()
[all …]
Dsequence_runner.cpp128 TaskManager::GetInstance().EnqueueTaskId(taskId, priority); in ExecuteTaskImmediately()
129 TaskManager::GetInstance().TryTriggerExpand(); in ExecuteTaskImmediately()
Dworker.h177 friend class TaskManager; variable
/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
Dtest_taskpool.cpp34 TaskManager &taskManager = TaskManager::GetInstance();
62 uint32_t workers = TaskManager::GetInstance().GetRunningWorkers();
69 TaskManager &taskManager = TaskManager::GetInstance();
76 TaskManager &taskManager = TaskManager::GetInstance();
84 TaskManager &taskManager = TaskManager::GetInstance();
165 TaskManager& taskManger = TaskManager::GetInstance();
182 TaskManager& taskManger = TaskManager::GetInstance();
192 TaskManager& taskManger = TaskManager::GetInstance();
204 TaskManager& taskManger = TaskManager::GetInstance();
216 TaskManager& taskManger = TaskManager::GetInstance();