Method Push

cpp/src/arrow/flight/sql/odbc/odbc_impl/blocking_queue.h:72–82

  }

  void Push(T item) {
    std::unique_lock<std::mutex> unique_lock(mtx_);
    if (!WaitUntilCanPushOrClosed(unique_lock)) return;

    buffer_[right_] = std::move(item);

    right_ = (right_ + 1) % capacity_;
    buffer_size_++;

    not_empty_.notify_one();
  }

  bool Pop(T* result) {
    std::unique_lock<std::mutex> unique_lock(mtx_);