1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
|
#pragma once
#include <deque>
#include <mutex>
#include <optional>
namespace advss {
template<class T> class MessageBuffer {
public:
bool Empty();
void Clear();
void AppendMessage(const T &);
std::optional<T> ConsumeMessage();
private:
std::deque<T> _buffer;
std::mutex _mutex;
};
template<class T> inline bool MessageBuffer<T>::Empty()
{
std::lock_guard<std::mutex> lock(_mutex);
return _buffer.empty();
}
template<class T> inline void MessageBuffer<T>::Clear()
{
std::lock_guard<std::mutex> lock(_mutex);
_buffer.clear();
}
template<class T> inline void MessageBuffer<T>::AppendMessage(const T &message)
{
std::lock_guard<std::mutex> lock(_mutex);
_buffer.emplace_back(message);
}
template<class T> inline std::optional<T> MessageBuffer<T>::ConsumeMessage()
{
std::lock_guard<std::mutex> lock(_mutex);
if (_buffer.empty()) {
return {};
}
T message = _buffer.at(0);
_buffer.pop_front();
return message;
}
} // namespace advss
|
