conqueue

Supporting material for paper: d2912r0: Concurrent queues and sender/receivers

Experimental implementation of concurrent buffer queue with adding sender/receiver based async_pop / async_push to https://wg21.link/p1958r0. Using reference implementation of sender/receiver from https://github.com/NVIDIA/stdexec.

Inspired by

• https://wg21.link/p0260r5 A proposal to add a concurrent queue to the standard library
• https://wg21.link/p1958r0 C++ Concurrent Buffer Queue
• https://wg21.link/p2882r0 An Event Model for C++ Executors

enum class conqueue_errc { success, empty, full, closed };
class conqueue_error : public system_error { ... };

template <typename T, typename Alloc = std::allocator<T>> class buffer_queue {
public:
  using value_type = T;

  explicit buffer_queue(size_t max_elems, Alloc alloc = Alloc());
  ~buffer_queue() noexcept;

  // observers
  bool is_closed() noexcept;
  size_t capacity() const noexcept;

  // modifiers
  void close() noexcept;

  T pop();
  std::optional<T> pop(std::error_code& ec);
  std::optional<T> try_pop(std::error_code& ec);

  void push(const T& x);
  bool push(const T& x, error_code& ec); // used to be wait_push
  bool try_push(const T& x, error_code& ec);

  void push(T&& x);
  bool push(T&& x, error_code& ec); // used to be wait_push
  bool try_push(T&& x, error_code& ec);

  // async modifiers
  push_sender async_push(const T& x) noexcept(is_nothrow_copy_constructible_v<T>);
  push_sender async_push(T&& x) noexcept(is_nothrow_move_constructible_v<T>);
  pop_sender async_pop() noexcept;
};