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