concurrent_queue.hpp

Go to the documentation of this file.

#ifndef OPENEV_CONTAINERS_CONCURRENT_QUEUE_HPP
#define OPENEV_CONTAINERS_CONCURRENT_QUEUE_HPP
 
#include "openev/core/types.hpp"
#include <boost/lockfree/spsc_queue.hpp>
#include <cstddef>
 
namespace ev {
[[maybe_unused]] constexpr bool USING_CONCURRENT_QUEUE_HPP = true;

template <typename T>
class ConcurrentQueue_ : public boost::lockfree::spsc_queue<Event_<T>> {
public:
  explicit ConcurrentQueue_(const std::size_t capacity) : boost::lockfree::spsc_queue<Event_<T>>{capacity}, capacity_{capacity} {}

  inline void clear() {
    while(boost::lockfree::spsc_queue<Event_<T>>::pop());
  }

  [[nodiscard]] inline bool empty() const {
    return boost::lockfree::spsc_queue<Event_<T>>::read_available() == 0;
  }

  [[nodiscard]] inline bool full() const {
    return boost::lockfree::spsc_queue<Event_<T>>::write_available() == 0;
  }

  [[nodiscard]] inline std::size_t size() const {
    return boost::lockfree::spsc_queue<Event_<T>>::read_available();
  }

  [[nodiscard]] inline std::size_t capacity() const {
    return capacity_;
  }
 
private:
  std::size_t capacity_;
};
 
using ConcurrentQueuei = ConcurrentQueue_<int>;    
using ConcurrentQueuel = ConcurrentQueue_<long>;   
using ConcurrentQueuef = ConcurrentQueue_<float>;  
using ConcurrentQueued = ConcurrentQueue_<double>; 
using ConcurrentQueue = ConcurrentQueuei;          
} // namespace ev
 
#endif // OPENEV_CONTAINERS_CONCURRENT_QUEUE_HPP