#include <MTDistributedCycledAnalogMsgDispatcher.h>
Public Member Functions | |
MTDistributedCycledAnalogMsgDispatcher (ThreadPool &thrPool, vector< DistributedAnalogMessageDispatcher * > &stCycledAnalogDispatchers) | |
virtual | ~MTDistributedCycledAnalogMsgDispatcher () |
virtual void | dispatchDelayerCycledIncomingAnalogMsgs () |
Protected Attributes | |
ThreadPool & | thr_pool |
vector < DistributedCycledAnalogMessagesDispatchJob > | jobs |
Definition at line 26 of file MTDistributedCycledAnalogMsgDispatcher.h.
MTDistributedCycledAnalogMsgDispatcher::MTDistributedCycledAnalogMsgDispatcher | ( | ThreadPool & | thrPool, | |
vector< DistributedAnalogMessageDispatcher * > & | stCycledAnalogDispatchers | |||
) |
MTDistributedCycledAnalogMsgDispatcher::~MTDistributedCycledAnalogMsgDispatcher | ( | ) | [virtual] |
Definition at line 11 of file MTDistributedCycledAnalogMsgDispatcher.cpp.
void MTDistributedCycledAnalogMsgDispatcher::dispatchDelayerCycledIncomingAnalogMsgs | ( | ) | [virtual] |
Implements DistributedCycledAnalogMsgDispatcher.
Definition at line 15 of file MTDistributedCycledAnalogMsgDispatcher.cpp.
References ThreadPool::dispatch(), ThreadPool::getNumThreads(), jobs, thr_pool, and ThreadPool::waitAll().
Definition at line 38 of file MTDistributedCycledAnalogMsgDispatcher.h.
Referenced by dispatchDelayerCycledIncomingAnalogMsgs().
vector< DistributedCycledAnalogMessagesDispatchJob > MTDistributedCycledAnalogMsgDispatcher::jobs [protected] |
Definition at line 39 of file MTDistributedCycledAnalogMsgDispatcher.h.
Referenced by dispatchDelayerCycledIncomingAnalogMsgs(), and MTDistributedCycledAnalogMsgDispatcher().