diff options
Diffstat (limited to 'src/message/thread_safe_queue.cpp')
-rw-r--r-- | src/message/thread_safe_queue.cpp | 21 |
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; + } + +} |