PulseEngineThreadController.h

/* Distributed under the Apache License, Version 2.0.
   See accompanying NOTICE file for details.*/
 
#pragma once
 
#include "engine/CommonDefs.h"
#include <thread>
 
class PULSE_DECL PulseEngineThreadController : public Loggable
{
public:
  PulseEngineThreadController(const std::string& logFilename) : Loggable(logFilename) {}
  virtual ~PulseEngineThreadController() = default;
 
  class PULSE_DECL Simulation
  {
    friend PulseEngineThreadController;
  public:
    Simulation(Logger& status);
    virtual ~Simulation() = default;
 
    virtual bool Execute() = 0;
 
    bool StopRequested() const { return m_StopRequested; }
 
  protected:
 
    // Logic used to stop simulating, such as patient death
    // Set m_StopRequested to true to request the stop
    // When a stop is requested, AdvanceAndTrack will no longer advance and track.
    virtual void StopCheck() { }
 
    Logger& m_Status; // Only used to pass status to controller log the as simulation is executing
    bool                              m_StopRequested = false;
    std::string                       m_BaseName;
    std::string                       m_OutputsDir  = "";
    std::string                       m_csvFilename = "";
    std::string                       m_logFilename = "";
    std::vector<std::string>          m_Reports; // Anything you want to tell the controller after a simulation
    std::unique_ptr<PhysiologyEngine> m_Pulse = nullptr;
  };
 
  bool Run(const std::vector<Simulation*>& PulseEngineThreads);
 
protected:
  void ControllerLoop();
  Simulation* GetNextSimulation();
  void Complete(Simulation*);
 
  size_t m_TotalSimulations=0;
  std::mutex  m_Mutex;
  std::vector<Simulation*> m_Remaining;
  std::vector<std::thread> m_Threads;
};