mirror of
https://codeberg.org/comaps/comaps
synced 2025-12-19 13:03:36 +00:00
e3e4a1985a
To expand with full Organic Maps and Maps.ME commits history run: git remote add om-historic [om-historic.git repo url] git fetch --tags om-historic git replace squashed-history historic-commits
37 lines
1.3 KiB
C++
37 lines
1.3 KiB
C++
#include "drape_frontend/drape_notifier.hpp"
|
|
#include "drape_frontend/message_subclasses.hpp"
|
|
|
|
#include "drape/drape_routine.hpp"
|
|
|
|
namespace df
|
|
{
|
|
DrapeNotifier::DrapeNotifier(ref_ptr<ThreadsCommutator> commutator)
|
|
: m_commutator(commutator)
|
|
, m_counter(kInvalidId + 1)
|
|
{}
|
|
|
|
uint64_t DrapeNotifier::Notify(ThreadsCommutator::ThreadName threadName,
|
|
base::DelayedThreadPool::Duration const & duration, bool repeating,
|
|
Functor && functor)
|
|
{
|
|
uint64_t const notifyId = m_counter++;
|
|
NotifyImpl(threadName, duration, repeating, notifyId, std::move(functor));
|
|
return notifyId;
|
|
}
|
|
|
|
void DrapeNotifier::NotifyImpl(ThreadsCommutator::ThreadName threadName,
|
|
base::DelayedThreadPool::Duration const & duration, bool repeating,
|
|
uint64_t notifyId, Functor && functor)
|
|
{
|
|
dp::DrapeRoutine::RunDelayed(duration,
|
|
[this, threadName, duration, repeating, notifyId, functor = std::move(functor)]() mutable
|
|
{
|
|
m_commutator->PostMessage(threadName,
|
|
make_unique_dp<NotifyRenderThreadMessage>(functor, notifyId),
|
|
MessagePriority::Normal);
|
|
if (repeating)
|
|
NotifyImpl(threadName, duration, repeating, notifyId, std::move(functor));
|
|
});
|
|
}
|
|
} // namespace df
|