parameter_value_refresher.h

Go to the documentation of this file.

#pragma once
 
#include <readerwriterqueue/readerwriterqueue.h>
 
#include <atomic>
#include <chrono>
#include <future>
#include <map>
 
class VirtualParameter;
 
class ParameterValueRefresher {
 public:
  ParameterValueRefresher();
 
  void start();
  void stop();
  void add(VirtualParameter *virtual_parameter);
  void remove(VirtualParameter *virtual_parameter);
 
 private:
  std::map<VirtualParameter *, std::atomic_int> parameters_;
  moodycamel::ReaderWriterQueue<VirtualParameter *> add_parameter_queue_;
  moodycamel::ReaderWriterQueue<VirtualParameter *> remove_parameter_queue_;
  std::atomic_bool running_;
  std::future<void> future_;
  std::atomic_bool update_needed_;
 
  void run();
};