mpmc_queue.hpp

#pragma once
 
#include <cstddef>
#include <type_traits>
 
#include "mpmc_queue_base.hpp"
#include "queue_typed_base.hpp"
 
namespace LibXR
{
template <typename Payload>
class MPMCQueue final : public QueueTypedBase<MPMCQueue<Payload>, Payload>,
                        public MPMCQueueBase
{
  static_assert(std::is_trivially_copyable_v<Payload>,
                "MPMCQueue requires trivially copyable payloads");
  static_assert(std::is_trivially_destructible_v<Payload>,
                "MPMCQueue requires trivially destructible payloads");
 
 public:
  using ValueType = Payload;  
  using QueueTypedBase<MPMCQueue<Payload>, Payload>::Pop;
  using QueueTypedBase<MPMCQueue<Payload>, Payload>::Push;
 
  explicit MPMCQueue(size_t capacity)
      : MPMCQueueBase(sizeof(Payload), capacity)
  {
  }
};
}  // namespace LibXR