My Project
|
#include <SpawnableTask.h>
Public Member Functions | |
SpawnableTask (bool spawn) | |
virtual | ~SpawnableTask () |
![]() | |
void | sendRestartMsg () |
void | sendStopMsg () |
void | sendHeartBeatMsg () |
virtual void | fwdTaskMsg (Msg *msg) |
![]() | |
RunnableTask (bool spawnThread) | |
virtual | ~RunnableTask () |
![]() | |
Runnable (bool spawnThread, RUN_FN(*runFn)) | |
Runnable (bool spawnThread, RUN_FN(*runFn), int priority) | |
virtual | ~Runnable () |
void | blockForever () |
void | spawn () |
Protected Member Functions | |
virtual void | processMsg (Msg *msg) |
void | run () |
![]() | |
GenericTask () | |
GenericTask (Thread *thread) | |
virtual | ~GenericTask () |
void | sendTaskMsg (Msg *msg) |
void | startThreads (void *arg) |
void | startThread (void *arg, unsigned order) |
unsigned | getMinStartOrder () |
bool | threadsNeedStarting () |
void | cancelThreads () |
void | cancelThread (unsigned order) |
unsigned | getMinCancelOrder () |
bool | threadsNeedCancelling () |
void | pingThreads (void *arg) |
void | raise (std::string name, int sigNo) |
Thread * | getThread (std::string name) |
bool | threadsAreRunning () |
void | shutdownConnection (int fd) |
virtual void | serviceMsgQ (void) |
virtual void | restart (void) |
virtual void | processTaskMsg (bool *stop) |
virtual void | respondToHeartBeat () |
virtual void | installTimer (Msg *msg) |
virtual void | installSignal (Msg *msg) |
virtual void | enableTimer (Msg *msg) |
virtual void | addHandler (Msg *msg) |
void | stepCommands () |
![]() | |
virtual void | broadcastReady () |
void | spawn (void *arg) |
Additional Inherited Members | |
![]() | |
static | RUN_FN (runFn) |
![]() | |
static | THREAD_START (startUp) |
![]() | |
Thread * | thread_ |
std::vector< Thread * > | threads_ |
PipeQ< Msg > | msgq_ |
gcp::util::FdSet | fdSet_ |
std::vector< Command * > | commands_ |
struct timeval * | timeOut_ |
TimeVal | commandTimeOut_ |
![]() | |
Thread * | spawnedThread_ |
bool | spawned_ |
RUN_FN * | runFn_ |
....................................................................... Define a template class for an object which can run in its own thread. This inherits the message queue mechanism from GenericTask for communciation with this thread, and spawnable capabilities from Runnable
|
inline |
Constructor. If spawn==true, then a call to spawn() will start this thread
|
inlinevirtual |
Destructor.
|
inlineprotectedvirtual |
This method should be defined by each inheriting task to process its own task-specific messages.
Exception | Method to process a message received on the Task message * queue |
Reimplemented from gcp::util::GenericTask< Msg >.
Reimplemented in gcp::util::GpibUsbController, gcp::util::DliPowerStripController, and TestClass.
|
inlineprotectedvirtual |
Force inheritors to define a run method.
Run method defaults to calling the serviceMsgQ() method below.
Reimplemented from gcp::util::GenericTask< Msg >.