summaryrefslogtreecommitdiffstats
path: root/src/uscxml/concurrency/BlockingQueue.h
blob: 3d457204d16faac7199587ed20b6aa233094bccb (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
#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() {
	}

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

	T pop() {
		tthread::lock_guard<tthread::mutex> lock(_mutex);
		while (_queue.empty()) {
			_cond.wait(_mutex);
		}
		T ret = _queue.front();
		_queue.pop_front();
		return ret;
	}

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

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

}
}

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