blob: 0826590efe120d7425fc59b2bea92e1cbb315788 (
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
47
48
49
50
51
52
53
54
|
#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 */
|
