Lines Matching refs:task

126 void ThreadPool::AddToExecuteQueue(QueueableTask* task)  in AddToExecuteQueue()  argument
131 m_ExecuteQueue.Enqueue(task); in AddToExecuteQueue()
138 void ThreadPool::AddToWaitQueue(QueueableWaitTask* task) in AddToWaitQueue() argument
143 m_WaitQueue.Enqueue(task->AsNonWaitableTask()); in AddToWaitQueue()
164 QueueableWaitTask* task = GetWaitTaskPointer(m_WaitQueue.Dequeue()); in WaitThreadFunc() local
165 GetWaitTaskBuffer()[m_WaitingCount] = task; in WaitThreadFunc()
168 GetWaitHandleBuffer()[m_WaitingCount + 1] = task->GetWaitObject()->GetHandle(); in WaitThreadFunc()
179 QueueableTask* task; in WaitThreadFunc() local
183 task = GetWaitTaskBuffer()[n - 1]->AsNonWaitableTask(); in WaitThreadFunc()
188 AddToExecuteQueue(task); in WaitThreadFunc()
211 if (QueueableTask* task = m_ExecuteQueue.Dequeue()) in ExecuteThreadFunc() local
224 task->Invoke(); in ExecuteThreadFunc()
278 if (QueueableTask* task = m_ExecuteQueue.Dequeue()) in ExecuteThreadFunc() local
291 task->Invoke(); in ExecuteThreadFunc()
305 void SingleThreadPool::AddToExecuteQueue(QueueableTask* task) in AddToExecuteQueue() argument
310 m_ExecuteQueue.Enqueue(task); in AddToExecuteQueue()
365 void nnosThreadPoolAddWaitTask(nnosThreadPool* p, nnosThreadPoolWaitTask* task) in nnosThreadPoolAddWaitTask() argument
368 ThreadPoolWaitTaskForC* pThreadPoolTask = reinterpret_cast<ThreadPoolWaitTaskForC*>(task); in nnosThreadPoolAddWaitTask()
372 void nnosThreadPoolAddTask(nnosThreadPool* p, nnosThreadPoolTask* task) in nnosThreadPoolAddTask() argument
375 ThreadPoolTaskForC* pThreadPoolTask = reinterpret_cast<ThreadPoolTaskForC*>(task); in nnosThreadPoolAddTask()