1 files changed, 21 insertions, 0 deletions
diff --git a/src/thread/queue.cpp b/src/thread/queue.cpp
new file mode 100644
index 0000000..d2ed7d2
--- /dev/null
+++ b/src/thread/queue.cpp
@@ -0,0 +1,21 @@
+#include "queue.hpp"
+
+namespace smtp::thread
+{
+    void Queue::Push( Message const &message)
+    {
+        std::lock_guard<std::mutex> lock{mMutex};
+        mMessageQueue.push( message );
+        mCondition.notify_one();
+    }
+
+    std::shared_ptr<Message> Queue::WaitAndPop()
+    {
+        std::unique_lock<std::mutex> lock{mMutex};
+        mCondition.wait(lock, [this](){return !mMessageQueue.empty();});
+        auto result = std::make_shared<Message>(mMessageQueue.front());
+        mMessageQueue.pop();
+        return result;
+    }
+
+}