Method BlockingGet

be/src/kudu/util/blocking_queue.h:85–105

Gets an element from the queue; if the queue is empty, blocks until the queue becomes non-empty, or until the deadline passes. If the queue has been shut down but there are still elements in the queue, it returns those elements as if the queue were not yet shut down. Returns: - OK if successful - TimedOut if the deadline passed - Aborted if the queue shut down

  // - TimedOut if the deadline passed
  // - Aborted if the queue shut down
  Status BlockingGet(T* out, MonoTime deadline = {}) {
    MutexLock l(lock_);
    while (true) {
      if (!queue_.empty()) {
        *out = std::move(queue_.front());
        queue_.pop_front();
        decrement_size_unlocked(*out);
        l.Unlock();
        not_full_.Signal();
        return Status::OK();
      }
      if (PREDICT_FALSE(shutdown_)) {
        return Status::Aborted("");
      }
      if (!deadline.Initialized()) {
        not_empty_.Wait();
      } else if (PREDICT_FALSE(!not_empty_.WaitUntil(deadline))) {
        return Status::TimedOut("");
      }
    }
  }

  // Get all elements from the queue and append them to a vector.
  //