template_queue.h

Go to the documentation of this file.

#ifndef TEMPLATE_QUEUE_H
#define TEMPLATE_QUEUE_H
#include <queue>
#include <boost/thread.hpp>
#include <boost/chrono.hpp>
#include <boost/thread.hpp>
#include <boost/chrono.hpp>
#include <iostream>
template <typename T>
class Queue
{
public:

  int getNumberOfEntriesInQueue()
  {
    int retVal = 0;
    boost::mutex::scoped_lock mlock(mutex_);
    retVal = queue_.size();
    return(retVal);
  }



        bool isQueueEmpty()
        {
                bool retVal = false;
                boost::mutex::scoped_lock mlock(mutex_);
                retVal = queue_.empty();
                return(retVal);
        }

        bool waitForIncomingObject(int timeOutInMs)
        {
                boost::mutex::scoped_lock mlock(mutex_);
                bool ret = true;
                boost::posix_time::time_duration td = boost::posix_time::millisec(timeOutInMs);
                while (queue_.empty() && (ret == true))
                {
                        ret = cond_.timed_wait(mlock, td);
                }
                return(ret);
        }

    T pop()
    {
      boost::mutex::scoped_lock mlock(mutex_);
      while (queue_.empty())
      {
        cond_.wait(mlock);
      }
      T item = queue_.front();
      queue_.pop();
      return item;
    }

    void pop(T& item)
    {
      boost::mutex::scoped_lock mlock(mutex_);
      while (queue_.empty())
      {
        cond_.wait(mlock);
      }
      item = queue_.front();
      queue_.pop();
    }

    void push(const T& item)
    {
      boost::mutex::scoped_lock mlock(mutex_);
      queue_.push(item);
      mlock.unlock();
      cond_.notify_one();
    }

    void push(T& item)
    {
      boost::mutex::scoped_lock mlock(mutex_);
      queue_.push(item);
      mlock.unlock();
      cond_.notify_one();
    }

private:
    std::queue<T> queue_;
    boost::mutex mutex_;
    boost::condition_variable cond_;
    };
#endif