AIEngine.h

Go to the documentation of this file.

 
#pragma once
 
#include "threadsafe/aithreadsafe.h"
#include "threadsafe/ConditionVariable.h"
#include "AIStatefulTask.h"
#include "utils/FuzzyBool.h"
#include "debug.h"
#include <list>
#include <chrono>
#include <boost/intrusive_ptr.hpp>
 
class AIEngine
{
 private:
  struct QueueElementComp;
  class QueueElement {
    private:
      boost::intrusive_ptr<AIStatefulTask> mStatefulTask;
 
    public:
      QueueElement(AIStatefulTask* stateful_task) : mStatefulTask(stateful_task) { }
      friend bool operator==(QueueElement const& e1, QueueElement const& e2) { return e1.mStatefulTask == e2.mStatefulTask; }
      friend bool operator!=(QueueElement const& e1, QueueElement const& e2) { return e1.mStatefulTask != e2.mStatefulTask; }
      friend struct QueueElementComp;
 
      AIStatefulTask const& stateful_task() const { return *mStatefulTask; }
      AIStatefulTask& stateful_task() { return *mStatefulTask; }
  };
  struct QueueElementComp {
    inline bool operator()(QueueElement const& e1, QueueElement const& e2) const;
  };
 
  using queued_type = std::list<QueueElement>;
 
  struct engine_state_st
  {
    queued_type list;
    bool waiting;
    engine_state_st() : waiting(false) { }
  };
 
  using engine_state_type = aithreadsafe::Wrapper<engine_state_st, aithreadsafe::policy::Primitive<aithreadsafe::ConditionVariable>>;
 
#ifndef DOXYGEN
 public:       // Used by AIStatefulTask.
  using clock_type = AIStatefulTask::clock_type;
  using duration_type = AIStatefulTask::duration_type;
#endif
 
 private:
  engine_state_type mEngineState;
  char const* mName;
  duration_type mMaxDuration;
  bool mHasMaxDuration;
 
 public:
  AIEngine(char const* name, float max_duration = 0.0f) : mName(name) { setMaxDuration(max_duration); }
 
  void add(AIStatefulTask* stateful_task);
 
  utils::FuzzyBool mainloop();
 
  void wake_up();
 
  void flush();
 
  char const* name() const { return mName; }
 
  void setMaxDuration(float max_duration);
 
  bool hasMaxDuration() const { return mHasMaxDuration; }
};