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