BlockingQueue.h

Go to the documentation of this file.

#ifndef BLOCKINGQUEUE_H_4LEVMY0N
#define BLOCKINGQUEUE_H_4LEVMY0N

#include "uscxml/Common.h"
#include <list>
#include <condition_variable>

namespace uscxml {

template <class T>
class BlockingQueue {
public:
    BlockingQueue() {}
    virtual ~BlockingQueue() {
    }

    virtual void push(const T& elem) {
        std::lock_guard<std::mutex> lock(_mutex);
        _queue.push_back(elem);
        _cond.notify_all();
    }

    virtual void push_front(const T& elem) {
        std::lock_guard<std::mutex> lock(_mutex);
        _queue.push_front(elem);
        _cond.notify_all();
    }

    virtual T pop() {
        std::lock_guard<std::mutex> lock(_mutex);
//      std::cout << "Popping from " << this << std::endl;
        while (_queue.empty()) {
            _cond.wait(_mutex);
        }
        T ret = _queue.front();
        _queue.pop_front();
        return ret;
    }

    virtual void clear() {
        std::lock_guard<std::mutex> lock(_mutex);
        _queue.clear();
    }

    virtual bool isEmpty() {
        std::lock_guard<std::mutex> lock(_mutex);
        return _queue.empty();
    }

protected:
    std::mutex _mutex;
    std::condition_variable_any _cond;
    std::list<T> _queue;
};

}

#endif /* end of include guard: BLOCKINGQUEUE_H_4LEVMY0N */