MessageQueue.hxx

Go to the documentation of this file.

#ifndef MESSAGE_QUEUE_HXX_
#define MESSAGE_QUEUE_HXX_
 
#include <condition_variable>
#include <mutex>
#include <deque>
#include <vector>
#include <functional>
#include <ciso646>
 
using Monitor = std::condition_variable;
using Mutex = std::mutex;
using MonitorUPtr = std::unique_ptr<Monitor>;
using MutexUPtr = std::unique_ptr<Mutex>;
template <typename Type> using Deque = std::deque<Type>;
template <typename Semaphore> using Lock = std::unique_lock<Semaphore>;
 
template <typename Event> class MessageQueue
{
 
public:
  using Enumerable = Deque<Event>;
 
  void push(Event &&event);
 
  bool peek(void) noexcept;
 
  Enumerable getEnumerable(void);
 
  /* These operators are deleted to prevent race hazards */
  MessageQueue(const MessageQueue &) = delete;
  MessageQueue &operator=(const MessageQueue &) = delete;
 
  MessageQueue() = default;
  MessageQueue(MessageQueue &&) = default;
  MessageQueue &operator=(MessageQueue &&) = default;
 
private:
  bool wakeCondition(void) const noexcept;
 
  MonitorUPtr m_OnEvent = std::make_unique<Monitor>();
  MutexUPtr m_Semaphore = std::make_unique<Mutex>();
  Deque<Event> m_Queue;
};
 
#include "MessageQueue.inl.hxx"
 
#endif