Lines Matching full:wait

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