parameter_value_refresher.h

Go to the documentation of this file.

#pragma once
 
#include <atomic>
#include <chrono>
#include <future>
#include <map>
 
#include "core/containers/thread_safe_queue.h"
 
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_;
  mm::core::containers::ThreadSafeQueue<VirtualParameter*> add_parameter_queue_;
  mm::core::containers::ThreadSafeQueue<VirtualParameter*>
      remove_parameter_queue_;
  std::atomic_bool running_;
  std::future<void> future_;
  std::atomic_bool update_needed_;
 
  void run();
};