Lines Matching refs:task
125 void ThreadPool::AddToExecuteQueue(QueueableTask* task) in AddToExecuteQueue() argument
130 m_ExecuteQueue.Enqueue(task); in AddToExecuteQueue()
137 void ThreadPool::AddToWaitQueue(QueueableWaitTask* task) in AddToWaitQueue() argument
142 m_WaitQueue.Enqueue(task->AsNonWaitableTask()); in AddToWaitQueue()
163 QueueableWaitTask* task = GetWaitTaskPointer(m_WaitQueue.Dequeue()); in WaitThreadFunc() local
164 GetWaitTaskBuffer()[m_WaitingCount] = task; in WaitThreadFunc()
167 GetWaitHandleBuffer()[m_WaitingCount + 1] = task->GetWaitObject()->GetHandle(); in WaitThreadFunc()
178 QueueableTask* task; in WaitThreadFunc() local
182 task = GetWaitTaskBuffer()[n - 1]->AsNonWaitableTask(); in WaitThreadFunc()
187 AddToExecuteQueue(task); in WaitThreadFunc()
210 if (QueueableTask* task = m_ExecuteQueue.Dequeue()) in ExecuteThreadFunc() local
223 task->Invoke(); in ExecuteThreadFunc()
290 void nnosThreadPoolAddWaitTask(nnosThreadPool* p, nnosThreadPoolWaitTask* task) in nnosThreadPoolAddWaitTask() argument
293 ThreadPoolWaitTaskForC* pThreadPoolTask = reinterpret_cast<ThreadPoolWaitTaskForC*>(task); in nnosThreadPoolAddWaitTask()
297 void nnosThreadPoolAddTask(nnosThreadPool* p, nnosThreadPoolTask* task) in nnosThreadPoolAddTask() argument
300 ThreadPoolTaskForC* pThreadPoolTask = reinterpret_cast<ThreadPoolTaskForC*>(task); in nnosThreadPoolAddTask()