From 1ca701a3056725f7560d10929baf3660d52bc4be Mon Sep 17 00:00:00 2001
From: claiff <claiff@mail.ru>
Date: Tue, 18 Oct 2022 16:52:46 +0300
Subject: waiting smtp recipients

---
 src/thread/queue.hpp | 29 +++++++++++++++++++++++++++++
 1 file changed, 29 insertions(+)
 create mode 100644 src/thread/queue.hpp

(limited to 'src/thread/queue.hpp')

diff --git a/src/thread/queue.hpp b/src/thread/queue.hpp
new file mode 100644
index 0000000..9ed3a76
--- /dev/null
+++ b/src/thread/queue.hpp
@@ -0,0 +1,29 @@
+#pragma once
+
+#include <string>
+#include <mutex>
+#include <queue>
+#include <condition_variable>
+
+namespace smtp::thread
+{
+    struct Message
+    {
+        std::string subject;
+        std::string text;
+    };
+
+    class Queue
+    {
+    public:
+        Queue() = default;
+        ~Queue() = default;
+
+        void Push( Message const& message );
+        std::shared_ptr<Message> WaitAndPop();
+    private:
+        mutable std::mutex mMutex;
+        std::queue<Message> mMessageQueue;
+        std::condition_variable mCondition;
+    };
+}
-- 
cgit v1.2.3