Queue.hpp

Go to the documentation of this file.

 
#ifndef IOMANAGER_INCLUDE_IOMANAGER_QUEUE_QUEUE_HPP_
#define IOMANAGER_INCLUDE_IOMANAGER_QUEUE_QUEUE_HPP_
 
#include "iomanager/queue/QueueBase.hpp"
#include "iomanager/queue/QueueIssues.hpp"
 
#include "ers/Issue.hpp"
#include "logging/Logging.hpp" // NOTE: if ISSUES ARE DECLARED BEFORE include logging/Logging.hpp, TLOG_DEBUG<<issue wont work.
 
#include <chrono>
#include <cstddef>
#include <memory>
#include <string>
#include <vector>
 
namespace dunedaq::iomanager {

template<class T>
class Queue : public QueueBase
{
public:
  using value_t = T;                            
  using duration_t = std::chrono::milliseconds; 

  explicit Queue(const std::string& name)
    : QueueBase(name)
  {
  }

  virtual bool can_push() const { return this->get_num_elements() < this->get_capacity(); }

  virtual bool can_pop() const { return this->get_num_elements() > 0; }

  virtual void push(value_t&& val, const duration_t& timeout) = 0;

  virtual void pop(value_t& val, const duration_t& timeout) = 0;
 
  virtual bool try_push(value_t&& val, const duration_t& timeout) = 0;
  virtual bool try_pop(value_t& val, const duration_t& timeout) = 0;
 
private:
  Queue(const Queue&) = delete;
  Queue& operator=(const Queue&) = delete;
  Queue(Queue&&) = delete;
  Queue& operator=(Queue&&) = delete;
};
 
} // namespace dunedaq::iomanager
 
#endif // IOMANAGER_INCLUDE_IOMANAGER_QUEUE_QUEUE_HPP_