-
9 #ifndef YAGE_UTIL_SYNCQUEUE_H
-
10 #define YAGE_UTIL_SYNCQUEUE_H
-
-
12 #include <condition_variable>
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
29 void push(
const T &item);
-
-
-
-
-
-
35 std::condition_variable cond_;
-
-
-
-
-
-
-
-
43 std::unique_lock<std::mutex> mlock(mutex_);
-
-
45 while (queue_.empty()) {
-
-
-
-
49 auto item = queue_.front();
-
-
-
-
-
-
-
-
57 std::unique_lock<std::mutex> mlock(mutex_);
-
-
59 while (queue_.empty()) {
-
-
-
-
63 item = queue_.front();
-
-
-
-
-
-
-
70 std::unique_lock<std::mutex> mlock(mutex_);
-
-
-
-
-
-
-
-
-
-
80 std::unique_lock<std::mutex> mlock(mutex_);
-
-
82 queue_.push(std::move(item));
-
-
-
-
-
-
-
+
+
+
11 #include <condition_variable>
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
28 void push(
const T &item);
+
+
+
+
+
+
34 std::condition_variable cond_;
+
+
+
+
+
+
+
+
42 std::unique_lock<std::mutex> mlock(mutex_);
+
+
44 while (queue_.empty()) {
+
+
+
+
48 auto item = queue_.front();
+
+
+
+
+
+
+
+
56 std::unique_lock<std::mutex> mlock(mutex_);
+
+
58 while (queue_.empty()) {
+
+
+
+
62 item = queue_.front();
+
+
+
+
+
+
+
69 std::unique_lock<std::mutex> mlock(mutex_);
+
+
+
+
+
+
+
+
+
+
79 std::unique_lock<std::mutex> mlock(mutex_);
+
+
81 queue_.push(std::move(item));
+
+
+
+
+
SyncQueue & operator=(const SyncQueue &)=delete
-
T pop()
Definition: syncqueue.h:41
-
void push(const T &item)
Definition: syncqueue.h:68
+
T pop()
Definition: syncqueue.h:40
+
void push(const T &item)
Definition: syncqueue.h:67
-
Definition: syncqueue.h:20
+
Definition: syncqueue.h:19