MultiThreadAnalogMsgDispatcher.h

Go to the documentation of this file.

#ifndef MultiThreadAnalogMsgDispatcher_H_
#define MultiThreadAnalogMsgDispatcher_H_

#include <boost/thread/barrier.hpp>

#include <iostream>

using std::cerr;
using std::endl;

#include "globaldefinitions.h"
#include "AnalogMessageDispatcher.h"
#include "SingleThreadAnalogMsgDispatcher.h"
#include "MTIncomingAnalogMessageDispatcher.h"

// The implementation is the same as in the single thread case 
// New type is used to clarify that it's purpose is different
typedef SingleThreadAnalogMsgDispatcher MTImmediateAnalogMsgDispatcher;


class MultiThreadAnalogMsgDispatcher : public AnalogMessageDispatcher
{
public:
    MultiThreadAnalogMsgDispatcher(delay_t minDelay)
            :   min_delay(minDelay)
    {
        currentStep = 0;
    }
    ;

    virtual ~MultiThreadAnalogMsgDispatcher();

    virtual void dispatchAnalogMsgs();

    virtual void initialize();

    virtual void setBarrier(boost::barrier *barrier)
    {
        thr_barrier = barrier;
    }

    SingleThreadAnalogMsgDispatcher & sTLocalDispatcher()
    {
        return st_analog_msgs_dispatcher;
    }

    MTImmediateAnalogMsgDispatcher & mTImmediateDispatcher()
    {
        return mt_incoming_immediate_analog_msgs_dispatcher;
    }

    MTIncomingAnalogMessageDispatcher &mTDelayedDispatcher()
    {
        return mt_incoming_delayed_analog_msgs_dispatcher;
        }
        
        void setMinDelay(delay_t delay) 
        {
          min_delay = delay;    
        }
        
        virtual void reset(double dt);
        

protected:
    SingleThreadAnalogMsgDispatcher st_analog_msgs_dispatcher;

    MTImmediateAnalogMsgDispatcher mt_incoming_immediate_analog_msgs_dispatcher;

    MTIncomingAnalogMessageDispatcher mt_incoming_delayed_analog_msgs_dispatcher;

    boost::barrier *thr_barrier;

    delay_t min_delay;
    
    int currentStep;
};

#endif /*MultiThreadAnalogMsgDispatcher_H_*/

---