Method WaitAndPop

cpp/src/arrow/acero/concurrent_queue_internal.h:36–40

Pops the last item from the queue but waits if the queue is empty until new items are pushed.

  // Pops the last item from the queue but waits if the queue is empty until new items are
  // pushed.
  T WaitAndPop() {
    std::unique_lock<std::mutex> lock(mutex_);
    WaitUntilNonEmpty(lock);
    return PopUnlocked();
  }

  // Pops the last item from the queue, or returns a nullopt if empty
  std::optional<T> TryPop() {