Lines Matching refs:TaskManager
103 TaskManager::GetInstance().InitTaskManager(env); in InitTaskPool()
110 auto* msgQueue = TaskManager::GetInstance().GetMessageQueue(req); in ExecuteCallback()
120 auto* msgQueue = TaskManager::GetInstance().GetMessageQueueFromCallbackInfo(callbackInfo); in ExecuteCallbackTask()
144 auto callbackInfo = TaskManager::GetInstance().GetCallbackInfo(resultInfo->taskId); in ExecuteCallbackInner()
150 TaskManager::GetInstance().ResetCallbackInfoWorker(callbackInfo); in ExecuteCallbackInner()
181 napi_value threadInfos = TaskManager::GetInstance().GetThreadInfos(env);
182 napi_value taskInfos = TaskManager::GetInstance().GetTaskInfos(env);
206 auto task = TaskManager::GetInstance().GetTask(taskId); in TerminateTask()
212 TaskManager::GetInstance().TerminateTask(taskId); in TerminateTask()
275 TaskManager::GetInstance().StoreTask(task->taskId_, task); in Execute()
284 auto task = TaskManager::GetInstance().GetTask(taskMessage->taskId); in DelayTask()
304 TaskManager::GetInstance().IncreaseRefCount(taskMessage->taskId); in DelayTask()
312 … TaskManager::GetInstance().EnqueueTaskId(taskMessage->taskId, Priority(taskMessage->priority)); in DelayTask()
511 TaskManager::GetInstance().DecreaseRefCount(task->env_, task->taskId_); in TriggerTask()
529 TaskManager::GetInstance().RemoveTask(task->taskId_); in TriggerTask()
536 TaskManager::GetInstance().DecreaseRefCount(task->env_, task->taskId_); in UpdateGroupInfoByResult()
568 auto task = TaskManager::GetInstance().GetTask(taskId); in UpdateGroupInfoByResult()
579 …auto task = iter != taskGroup->taskIds_.end() ? TaskManager::GetInstance().GetTask(*iter) : nullpt… in UpdateGroupInfoByResult()
602 TaskManager::GetInstance().IncreaseRefCount(task->taskId_); in ExecuteTask()
606 TaskManager::GetInstance().EnqueueTaskId(task->taskId_, priority); in ExecuteTask()
636 TaskManager::GetInstance().CancelTask(env, taskId); in Cancel()
684 TaskManager::GetInstance().IncreaseRefCount(task->taskId_); in PeriodicTaskCallback()
706 TaskManager::GetInstance().EnqueueTaskId(task->taskId_, task->periodicTaskPriority_); in PeriodicTaskCallback()