Monitoring and heartbeat

monitoring.cpp

#include <thread>
#include <chrono>

class Monitor
{
public:
  void onHeartbeat(int id, int status)
  {
    lastTimestamp = std::chrono::system_clock::now();
  }

private:
  std::chrono::system_clock::time_point firstTimestamp;
  std::chrono::system_clock::time_point lastTimestamp;
};

class Monitored
{
public:
  Monitored(int id) : _id(id)
  {
    _thread = std::thread([this]{
      while(true)
      {
        std::this_thread::sleep_for(std::chrono::milliseconds(500));
        sendHeartbeat(_id, _status, _sequenceNumber);
      }
    });
  }

  ~Monitored()
  {
    _thread.join();
  }

  void setStatus(int status)
  {
    _status = status;
  }

private:
  int _id;
  std::thread _thread;
  std::atomic<int> _status;
  int _sequenceNumber{0};
};

int main()
{
}