async_state_machine.hpp

Go to the documentation of this file.

//                                                                                                  //
// This file is part of the Seadex yasmine ecosystem (http://yasmine.seadex.de).                    //
// Copyright (C) 2016-2017 Seadex GmbH                                                              //
//                                                                                                  //
// Licensing information is available in the folder "license" which is part of this distribution.   //
// The same information is available on the www @ http://yasmine.seadex.de/Licenses.html.           //
//                                                                                                  //


#ifndef ASYNC_STATE_MACHINE_5D531F9B_A0F2_47FF_BCFC_3264896355C5
#define ASYNC_STATE_MACHINE_5D531F9B_A0F2_47FF_BCFC_3264896355C5


#include <list>

#include "essentials/compatibility/thread.hpp"
#include "essentials/compatibility/chrono.hpp"

#include "state_machine_base.hpp"
#include "async_event_handler.hpp"
#include "state_machine_status.hpp"


namespace sxy
{


class async_state_machine SX_FINAL:
 public state_machine_base, private async_event_handler
{
public:
 explicit async_state_machine( const std::string& _name, 
  event_processing_callback* const _event_processing_callback = SX_NULLPTR );
 virtual ~async_state_machine() SX_NOEXCEPT SX_OVERRIDE;
 SX_NO_COPY(async_state_machine)

 virtual bool fire_event( const event_sptr& _event ) SX_OVERRIDE;

 virtual bool run() SX_OVERRIDE;

 void halt_and_join();

 virtual void halt() SX_OVERRIDE;

 void join();


 bool wait( const sxe::milliseconds _timeoutInMs ) const;

 void wait() const;

 bool terminated() const;

 
 virtual bool push( const event_sptr& _event ) SX_OVERRIDE;


protected:
 void start_state_machine();


private:
 bool insert( const event_sptr& _event );
 void insert_impl( const event_sptr& _event );
 bool wait_predicate() const;
 bool wait_stop_condition() const;
 void work();

 virtual void on_event( const event_sptr& _event ) SX_OVERRIDE;
 virtual void interrupt_impl() SX_OVERRIDE;


 state_machine_status status_;
 mutable sxe::mutex run_and_event_mutex_;
 sxe::condition_variable run_and_event_condition_;
 mutable sxe::condition_variable terminated_condition_;
 sxe::SX_UNIQUE_PTR< sxe::thread > worker_thread_;
 std::list<event_sptr> event_list_;
};


}


#endif