Method Shutdown

be/src/kudu/util/blocking_queue.h:217–222

Shuts down the queue. When a blocking queue is shut down, no more elements can be added to it, and Put() will return QUEUE_SHUTDOWN. Existing elements will drain out of it, and then BlockingGet will start returning false.

  // Existing elements will drain out of it, and then BlockingGet will start
  // returning false.
  void Shutdown() {
    MutexLock l(lock_);
    shutdown_ = true;
    not_full_.Broadcast();
    not_empty_.Broadcast();
  }

  bool empty() const {
    MutexLock l(lock_);