18#ifndef _MAP_UPDATER_H_INCLUDED
19#define _MAP_UPDATER_H_INCLUDED
24#include <condition_variable>
34 MapUpdater() : _cancelationToken(false), pending_requests(0) {}
39 void schedule_update(
Map& map,
uint32 diff);
43 void activate(
size_t num_threads);
60 void update_finished();
std::vector< std::thread > _workerThreads
std::atomic< bool > _cancelationToken
ProducerConsumerQueue< MapUpdateRequest * > _queue
std::condition_variable _condition