#ifndef BLOCKINGQUEUE_H_4LEVMY0N
#define BLOCKINGQUEUE_H_4LEVMY0N

#include "uscxml/concurrency/tinythread.h"
#include <list>

namespace uscxml {
namespace concurrency {

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

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

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

	virtual T pop() {
		tthread::lock_guard<tthread::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 bool isEmpty() {
		tthread::lock_guard<tthread::mutex> lock(_mutex);
		return _queue.empty();
	}

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

}
}

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