Nebula
Loading...
Searching...
No Matches
runthroughhandlerthread.h
Go to the documentation of this file.
1#pragma once
2//------------------------------------------------------------------------------
14#include "threading/safequeue.h"
15
16//------------------------------------------------------------------------------
17namespace Messaging
18{
20{
22public:
25
27 virtual void AddMessage(const Ptr<Message>& msg);
29 virtual void CancelMessage(const Ptr<Message>& msg);
30
32 virtual void DoWork();
33
34private:
36};
37
38} // namespace Messaging
39//------------------------------------------------------------------------------
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