blob: e2d39703eef33935392a5b2c39a6fb69db8f0ed8 (
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
|
#include "qmapboxgl_scheduler.hpp"
#include <mbgl/util/util.hpp>
#include <cassert>
QMapboxGLScheduler::QMapboxGLScheduler()
{
}
QMapboxGLScheduler::~QMapboxGLScheduler()
{
MBGL_VERIFY_THREAD(tid);
}
void QMapboxGLScheduler::schedule(std::weak_ptr<mbgl::Mailbox> mailbox)
{
std::lock_guard<std::mutex> lock(m_taskQueueMutex);
m_taskQueue.push(mailbox);
// Need to force the main thread to wake
// up this thread and process the events.
emit needsProcessing();
}
void QMapboxGLScheduler::processEvents()
{
std::queue<std::weak_ptr<mbgl::Mailbox>> taskQueue;
{
std::unique_lock<std::mutex> lock(m_taskQueueMutex);
std::swap(taskQueue, m_taskQueue);
}
while (!taskQueue.empty()) {
mbgl::Mailbox::maybeReceive(taskQueue.front());
taskQueue.pop();
}
}
|