Lines Matching refs:ThreadManager
43 } ThreadManager;
66 static ThreadManager *g_threadManager = NULL;
91 static TaskExecuteNode *PopTaskExecutor(ThreadManager *mgr)
106 static int AddExecutor(ThreadManager *mgr, const TaskNode *task)
127 static void RunExecutor(ThreadManager *mgr, ThreadNode *threadNode, uint32_t maxCount)
152 static TaskNode *GetTask(ThreadManager *mgr, ListNode *queue, uint32_t taskId)
177 static TaskNode *PopTask(ThreadManager *mgr, ListNode *queue)
191 static void PushTask(ThreadManager *mgr, TaskNode *task, ListNode *queue)
199 static void SafeRemoveTask(ThreadManager *mgr, TaskNode *task)
224 static void ExecuteTask(ThreadManager *mgr)
237 static void CheckTaskComplete(ThreadManager *mgr)
272 ThreadManager *mgr = (ThreadManager *)malloc(sizeof(ThreadManager) + maxThreadCount * sizeof(ThreadNode));
307 ThreadManager *mgr = (ThreadManager *)instance;
340 ThreadManager *mgr = (ThreadManager *)instance;
367 ThreadManager *mgr = (ThreadManager *)instance;
386 ThreadManager *mgr = (ThreadManager *)instance;
411 ThreadManager *mgr = (ThreadManager *)instance;
440 ThreadManager *mgr = (ThreadManager *)instance;
457 static void CheckAndCreateNewThread(ThreadManager *mgr)
491 ThreadManager *mgr = g_threadManager;
528 ThreadManager *mgr = g_threadManager;