MTDistributedCycledAnalogMsgDispatcher.h

Go to the documentation of this file.

#ifndef MTDistributedCycledAnalogMsgDispatcher_H_
#define MTDistributedCycledAnalogMsgDispatcher_H_

#include "DistributedAnalogMessageDispatcher.h"
#include "DistributedCycledAnalogMsgDispatcher.h"
#include "ThreadPool.h"

class DistributedCycledAnalogMessagesDispatchJob : public ThreadPoolJob
{
public:
    DistributedCycledAnalogMessagesDispatchJob(DistributedCycledAnalogMsgDispatcher
                                                                                *cycledAnalogMsgDispatcher)
                                                        : _cycledAnalogMsgDispatcher(cycledAnalogMsgDispatcher)
    {}

    virtual void start()
    {
        _cycledAnalogMsgDispatcher->dispatchDelayerCycledIncomingAnalogMsgs();
    }

protected:
    DistributedCycledAnalogMsgDispatcher * _cycledAnalogMsgDispatcher;
};


class MTDistributedCycledAnalogMsgDispatcher : public DistributedCycledAnalogMsgDispatcher
{
public:

    MTDistributedCycledAnalogMsgDispatcher(ThreadPool &thrPool,
                                       vector< DistributedAnalogMessageDispatcher *> & stCycledAnalogDispatchers);

    virtual ~MTDistributedCycledAnalogMsgDispatcher();

    virtual void dispatchDelayerCycledIncomingAnalogMsgs();
    
protected:
        ThreadPool &thr_pool;
        vector< DistributedCycledAnalogMessagesDispatchJob > jobs;    
};

#endif /*MTDistributedCycledAnalogMsgDispatcher_H_*/

---