summaryrefslogtreecommitdiffstats
path: root/src/uscxml/concurrency/BlockingQueue.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/uscxml/concurrency/BlockingQueue.h')
-rw-r--r--src/uscxml/concurrency/BlockingQueue.h30
1 files changed, 15 insertions, 15 deletions
diff --git a/src/uscxml/concurrency/BlockingQueue.h b/src/uscxml/concurrency/BlockingQueue.h
index 90094bf..16c23d4 100644
--- a/src/uscxml/concurrency/BlockingQueue.h
+++ b/src/uscxml/concurrency/BlockingQueue.h
@@ -12,26 +12,26 @@ class BlockingQueue {
public:
BlockingQueue() {}
virtual ~BlockingQueue() {
- }
+ }
void push(T elem) {
- tthread::lock_guard<tthread::mutex> lock(_mutex);
- _queue.push_back(elem);
- _cond.notify_all();
- }
-
+ 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;
- }
+ tthread::lock_guard<tthread::mutex> lock(_mutex);
+ while (_queue.empty()) {
+ _cond.wait(_mutex);
+ }
+ T ret = _queue.front();
+ _queue.pop_front();
+ return ret;
+ }
tthread::mutex _mutex;
- tthread::condition_variable _cond;
+ tthread::condition_variable _cond;
std::list<T> _queue;
};