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