AsyncEventHandler.hh

Go to the documentation of this file.

#ifndef ASYNC_EVENT_HANDLER_h
#define ASYNC_EVENT_HANDLER_h

#ifndef SINGLETHREAD
#include "boost/thread/condition_variable.hpp"
#include "boost/thread/mutex.hpp"
#include "boost/thread.hpp"
#endif

#include "Event.hh"
#include <vector>

class BaseModule;

class AsyncEventHandler{
public:
  AsyncEventHandler();
  ~AsyncEventHandler();
  
  void Reset();
  
  int AddModule(BaseModule* mod, bool register_to_eventhandler = true,
                bool register_parameters = true);
  
  int AddReceiver(AsyncEventHandler* receiver);
  
  int Process(EventPtr evt);
  
  int StartRunning();
  int StopRunning();
  bool IsRunning(){ return _running; }
  
  void SetSleepMillisec(int sleeptime){ _sleeptime = sleeptime;}
  int GetSleepMillisec() const { return _sleeptime; }
  
  void SetBlockingStatus(bool blocking){ _blocking = blocking; }
  bool GetBlockingStatus(){ return _blocking; }
  
  void operator()();  

private:
  bool _running;            
  int _sleeptime;           
  bool _blocking;           
  std::vector<BaseModule*> _modules;          
  std::vector<AsyncEventHandler*> _receivers; 
  EventPtr _next_event;                  
#ifndef SINGLETHREAD
  boost::condition_variable _event_ready; 
  boost::mutex _event_mutex;      
  boost::shared_ptr<boost::thread> _threadptr; 
#endif
};  

#endif