add smtp queue messages

1 files changed, 21 insertions, 0 deletions

diff --git a/src/message/thread_safe_queue.cpp b/src/message/thread_safe_queue.cpp
new file mode 100644
index 0000000..092a2ac
--- /dev/null
+++ b/src/message/thread_safe_queue.cpp
@@ -0,0 +1,21 @@
+#include "thread_safe_queue.hpp"
+
+namespace smtp::message
+{
+    void ThreadSafeQueue::Push( Message const &message)
+    {
+        std::lock_guard<std::mutex> lock{mMutex};
+        mMessageQueue.push( message );
+        mCondition.notify_one();
+    }
+
+    std::shared_ptr<Message> ThreadSafeQueue::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;
+    }
+
+}