/// @copyright 2020 ECCI, Universidad de Costa Rica. All rights reserved
/// This code is released under the GNU Public License version 3
/// @author Jeisson Hidalgo-Céspedes <jeisson.hidalgo@ucr.ac.cr>

#ifndef PRODUCER_HPP
#define PRODUCER_HPP

#include <cassert>

#include "Queue.hpp"
#include "Thread.hpp"

/**
 * @brief A template that generates abstract base classes for Producers
 * Producers are execution threads. They create elements that are pushed
 * to a queue. These elements will be popped by a consumer thread.
 */
template <typename DataType>
class Producer : public Thread {
  DISABLE_COPY(Producer);

 protected:
  /// This thread will produce for this queue
  Queue<DataType>* queue;

 public:
  /// Constructor
  explicit Producer(Queue<DataType>* queue = nullptr)
    : queue(queue) {
  }
  /// Destructor
  virtual ~Producer() {
  }
  /// Set the queue where this thread will produce elements
  inline void setQueue(Queue<DataType>* queue) {
    this->queue = queue;
  }
  /// Add to the queue the produced data unit
  virtual void produce(const DataType& data) {
    assert(this->queue);
    this->queue->push(data);
  }
};

#endif  // PRODUCER_HPP