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.hpp | |
parent | 416a20b211539c8db06c26a2297de9109ef69f32 (diff) | |
download | obmc-sila-smtp-1ca701a3056725f7560d10929baf3660d52bc4be.tar.xz |
waiting smtp recipientsbugfix/queue_empty_recipients
Diffstat (limited to 'src/thread/queue.hpp')
-rw-r--r-- | src/thread/queue.hpp | 29 |
1 files changed, 29 insertions, 0 deletions
diff --git a/src/thread/queue.hpp b/src/thread/queue.hpp new file mode 100644 index 0000000..9ed3a76 --- /dev/null +++ b/src/thread/queue.hpp @@ -0,0 +1,29 @@ +#pragma once + +#include <string> +#include <mutex> +#include <queue> +#include <condition_variable> + +namespace smtp::thread +{ + struct Message + { + std::string subject; + std::string text; + }; + + class Queue + { + public: + Queue() = default; + ~Queue() = default; + + void Push( Message const& message ); + std::shared_ptr<Message> WaitAndPop(); + private: + mutable std::mutex mMutex; + std::queue<Message> mMessageQueue; + std::condition_variable mCondition; + }; +} |