diff options
author | claiff <claiff@mail.ru> | 2022-10-18 16:52:46 +0300 |
---|---|---|
committer | claiff <claiff@mail.ru> | 2022-10-18 16:52:46 +0300 |
commit | 1ca701a3056725f7560d10929baf3660d52bc4be (patch) | |
tree | a1fb1fe43cb4066e7cc86e068898aee40eebb2f7 /src/thread/queue.cpp | |
parent | 416a20b211539c8db06c26a2297de9109ef69f32 (diff) | |
download | obmc-sila-smtp-bugfix/queue_empty_recipients.tar.xz |
waiting smtp recipientsbugfix/queue_empty_recipients
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; + } + +} |