1 files changed, 29 insertions, 0 deletions
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;
+    };
+}