AITimer.h

Go to the documentation of this file.

 
#pragma once
 
#include "AIStatefulTask.h"
#include "threadpool/Timer.h"
#include <atomic>
 
class AITimer : public AIStatefulTask
{
 protected:
  using direct_base_type = AIStatefulTask;
 
  enum timer_state_type {
    AITimer_start = direct_base_type::state_end,
    AITimer_expired
  };
 
 public:
  static constexpr state_type state_end = AITimer_expired + 1;
 
 private:
  std::atomic_bool mHasExpired;                 
  threadpool::Timer mTimer;                     
  threadpool::Timer::Interval mInterval;        
 
 public:
  AITimer(CWDEBUG_ONLY(bool debug = false)) :
#ifdef CWDEBUG
    AIStatefulTask(debug),
#endif
    mHasExpired(false), mTimer([this](){ expired(); }) { DoutEntering(dc::statefultask(mSMDebug), "AITimer::AITimer() [" << (void*)this << "]"); }
 
  void set_interval(threadpool::Timer::Interval interval) { mInterval = interval; }
 
  threadpool::Timer::Interval const& get_interval() const { return mInterval; }
 
 protected:
  ~AITimer() override { DoutEntering(dc::statefultask(mSMDebug), "AITimer::~AITimer() [" << (void*)this << "]"); /* mFrameTimer.cancel(); */ }
 
  char const* state_str_impl(state_type run_state) const override;
  char const* task_name_impl() const override;
 
  void multiplex_impl(state_type run_state) override;
 
  void abort_impl() override;
 
 private:
  // This is the callback for mFrameTimer.
  void expired();
};