runner.h

Go to the documentation of this file.

#pragma once
#include "event_aggregator.h"
#include "simulation.h"
 
#include <atomic>
#include <functional>
#include <memory>
#include <stop_token>
 
namespace hgps {
 
class Runner {
  public:
    Runner() = delete;
 
    Runner(std::shared_ptr<EventAggregator> bus,
           std::unique_ptr<RandomBitGenerator> seed_generator) noexcept;
 
    double run(Simulation &baseline, const unsigned int trial_runs);
 
    double run(Simulation &baseline, Simulation &intervention, const unsigned int trial_runs);
 
    bool is_running() const noexcept;
 
    void cancel() noexcept;
 
  private:
    std::atomic<bool> running_;
    std::shared_ptr<EventAggregator> event_bus_;
    std::unique_ptr<RandomBitGenerator> seed_generator_;
    std::stop_source source_;
    std::string runner_id_{};
 
    void run_model_thread(const std::stop_token &token, Simulation &model, unsigned int run,
                          unsigned int seed);
 
    void notify(std::unique_ptr<hgps::EventMessage> message);
};
 
} // namespace hgps