blob: bdb63429db7173d8be18df657dfe83630f95b90f (
plain)
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
50
51
|
#pragma once
#include "drape_frontend/message.hpp"
#include "drape/drape_diagnostics.hpp"
#include "drape/pointers.hpp"
#include "base/condition.hpp"
#include <condition_variable>
#include <deque>
#include <functional>
#include <mutex>
namespace df
{
class MessageQueue
{
public:
MessageQueue();
~MessageQueue();
// If the queue is empty then it returns nullptr or wait for a message.
drape_ptr<Message> PopMessage(bool waitForMessage);
void PushMessage(drape_ptr<Message> && message, MessagePriority priority);
void CancelWait();
void ClearQuery();
using FilterMessageFn = std::function<bool(ref_ptr<Message>)>;
void EnableMessageFiltering(FilterMessageFn && filter);
void DisableMessageFiltering();
void InstantFilter(FilterMessageFn && filter);
#ifdef DEBUG_MESSAGE_QUEUE
bool IsEmpty() const;
size_t GetSize() const;
#endif
private:
void FilterMessagesImpl();
void CancelWaitImpl();
mutable std::mutex m_mutex;
std::condition_variable m_condition;
bool m_isWaiting;
using TMessageNode = std::pair<drape_ptr<Message>, MessagePriority>;
std::deque<TMessageNode> m_messages;
std::deque<drape_ptr<Message>> m_lowPriorityMessages;
FilterMessageFn m_filter;
};
} // namespace df
|
