Lines Matching full:wait
67 // Wait for tasks to be pushed in the queue in processTasks()
68 QueueCondition.wait(LockGuard, [&] { in processTasks()
82 // in order for wait() to properly detect that even if the queue is in processTasks()
88 // would never be 0 if waiting for another group inside a wait. in processTasks()
113 // Adjust `ActiveThreads`, in case someone waits on StdThreadPool::wait() in processTasks()
125 // someone waits on StdThreadPool::wait(). in processTasks()
129 // in this function on QueueCondition, to make a recursive wait() return in processTasks()
144 void StdThreadPool::wait() { in wait() function in StdThreadPool
146 // Wait for all threads to complete and the queue to be empty in wait()
148 CompletionCondition.wait(LockGuard, in wait()
152 void StdThreadPool::wait(ThreadPoolTaskGroup &Group) { in wait() function in StdThreadPool
153 // Wait for all threads in the group to complete. in wait()
156 CompletionCondition.wait(LockGuard, in wait()
201 void SingleThreadExecutor::wait() { in wait() function in SingleThreadExecutor
210 void SingleThreadExecutor::wait(ThreadPoolTaskGroup &) { in wait() function in SingleThreadExecutor
211 // Simply wait for all, this works even if recursive (the running task in wait()
213 wait(); in wait()
220 SingleThreadExecutor::~SingleThreadExecutor() { wait(); } in ~SingleThreadExecutor()