Base class for AsyncPort message handler thread classes.
Definition handlerthreadbase.h:22
A simple handler thread class which "runs thru", and doesn't wait for messages.
Definition runthroughhandlerthread.h:20
__DeclareClass(RunThroughHandlerThread)
virtual void CancelMessage(const Ptr< Message > &msg)
cancel a pending message (override in subclass!)
Definition runthroughhandlerthread.cc:38
RunThroughHandlerThread()
constructor
Definition runthroughhandlerthread.cc:16
Threading::SafeQueue< Ptr< Message > > msgQueue
Definition runthroughhandlerthread.h:35
virtual void AddMessage(const Ptr< Message > &msg)
add a message to be handled (override in subclass!)
Definition runthroughhandlerthread.cc:26
virtual void DoWork()
this method runs in the thread context
Definition runthroughhandlerthread.cc:49
Nebula's smart pointer class which manages the life time of RefCounted objects.
Definition ptr.h:38
Thread-safe version of Util::Queue.
Definition safequeue.h:27
Definition asyncport.cc:10