Lines Matching refs:executor
63 TaskExecutor executor; member
93 TaskExecuteNode *executor = NULL; in PopTaskExecutor() local
99 executor = ListEntry(node, TaskExecuteNode, executeNode); in PopTaskExecutor()
103 return executor; in PopTaskExecutor()
110 TaskExecuteNode *executor = ListEntry(node, TaskExecuteNode, node); in AddExecutor() local
112 task->taskId, mgr->executorCount, executor->task->taskId); in AddExecutor()
116 OH_ListRemove(&executor->executeNode); in AddExecutor()
117 OH_ListInit(&executor->executeNode); in AddExecutor()
118 OH_ListAddTail(&mgr->executorQueue, &executor->executeNode); in AddExecutor()
131 TaskExecuteNode *executor = PopTaskExecutor(mgr); in RunExecutor() local
133 while (executor != NULL && !threadNode->threadExit) { in RunExecutor()
134 APPSPAWN_LOGV("RunExecutor task: %{public}u", executor->task->taskId); in RunExecutor()
135 atomic_fetch_add(&executor->task->finishTaskCount, 1); in RunExecutor()
136 executor->executor(executor->task->taskId, executor->context); in RunExecutor()
141 executor = PopTaskExecutor(mgr); in RunExecutor()
210 TaskExecuteNode *executor = ListEntry(node, TaskExecuteNode, node); in SafeRemoveTask() local
212 if (!ListEmpty(executor->executeNode)) { in SafeRemoveTask()
213 OH_ListRemove(&executor->executeNode); in SafeRemoveTask()
214 OH_ListInit(&executor->executeNode); in SafeRemoveTask()
218 free(executor); in SafeRemoveTask()
365 ThreadTaskHandle taskHandle, TaskExecutor executor, const ThreadContext *context) in ThreadMgrAddExecutor() argument
378 node->executor = executor; in ThreadMgrAddExecutor()