fesa-core
5.0.1
|
#include <MultiThreadedEventSourceProducer.h>
Public Member Functions | |
MultiThreadedEventSourceProducer (MultiThreadedEventSource &eventSource) | |
void | run () |
this method has to be overridden to provide the logic for the thread. It has to contain the code that will be executed in the thread | |
void | disable () |
void | enable () |
Public Member Functions inherited from fesa::Thread | |
Thread () | |
Constructor. More... | |
virtual | ~Thread () |
Destructor. | |
void | setDetachState (int32_t state) |
Modify the detach state of the thread. More... | |
void | start (bool blockingMode, const std::string &threadName, bool permanent=true) |
virtual void | stop () |
Stop the thread. | |
int | join (void **status) |
bool | isRunning () const |
Check if the thread is running. More... | |
pthread_t | getID () const |
Get the process ID. More... | |
int32_t | getPriority () const |
Get the priority of the thread. More... | |
cpu_set_t | getAffinity () const |
Get the affinity of the thread. | |
void | setPriority (int32_t priority) |
Set the priority of the thread. More... | |
void | setAffinity (cpu_set_t affinity) |
Set the affinity of the thread. More... | |
Additional Inherited Members | |
Static Public Member Functions inherited from fesa::Thread | |
static void | AdjustProcessScheduling () |
The process priority can only be adjusted in the main thread. It needs to be adjusted to the maximal thread priority since it sets the limit of the thread priorities of this process. More... | |
static std::string | getThreadName (pthread_t threadId) |
Get the name of the thread by its id. More... | |
static std::string | getCurrentThreadName () |
static void | registerThreadIdName (pthread_t threadId, const std::string &threadName) |
Associate a thread id with a name. More... | |
static void | registerThreadId (pthread_t threadId, Thread *thread) |
Associate a thread id with a name. More... | |
static Thread * | current () |
Returns the Thread object associated with the current thread. | |
static Thread * | getById (pthread_t id) |
Returns the Thread object associated with the given id. Throws FesaException if the id is unknown. More... | |
static const std::set< const Thread * > | getThreads () |
Protected Attributes inherited from fesa::Thread | |
bool | isRunning_ |
true if the thread is running | |
bool | hasFinished_ |
true if the thread has finished. | |
bool | joinHasFinished_ |
if true, a call to pthread_join has completed and a further pthread_cancel / pthread_join call is unsafe | |
bool | permanent_ |
pthread_t | tid_ |
Id of this thread. | |
Abstract class for producers in the context of a MultiThreadedEventSource.
fesa::MultiThreadedEventSourceProducer::MultiThreadedEventSourceProducer | ( | MultiThreadedEventSource & | eventSource | ) |
Constructor. This producer will be enabled by default, but can be disabled before it is started if needed.
eventSource | the source to which events will be posted. |
void fesa::MultiThreadedEventSourceProducer::disable | ( | ) |
Disables this producer.
void fesa::MultiThreadedEventSourceProducer::enable | ( | ) |
Enables this producer.