Valkka
1.6.1
OpenSource Video Management
|
A demo thread for testing the producer/consumer module for fifos. More...
#include <thread.h>
Public Member Functions | |
TestConsumerThread (const char *name, FrameFifo *framefifo) | |
void | run () |
Main execution loop is defined here. | |
void | preRun () |
Called before entering the main execution loop, but after creating the thread. | |
void | postRun () |
Called after the main execution loop exits, but before joining the thread. | |
Public Member Functions inherited from Thread | |
Thread (const char *name) | |
Default constructor. More... | |
~Thread () | |
Destructor:not virtual. More... | |
virtual void | preJoin () |
Called before the thread is joined. | |
virtual void | postJoin () |
Called after the thread has been joined. | |
virtual void | sendSignal (SignalContext signal_ctx) |
Send a signal to the thread. | |
virtual void | sendSignalAndWait (SignalContext signal_ctx) |
Send a signal to the thread and wait for all signals to be executed. | |
void | setAffinity (int i) |
API method for setting the thread affinity. More... | |
void | startCall () |
API method: starts the thread. | |
virtual void | stopCall () |
API method: stops the thread. More... | |
virtual void | requestStopCall () |
API method: stops the thread. More... | |
virtual void | waitStopCall () |
API method: waits until the thread is joined. More... | |
virtual void | waitReady () |
Wait until thread has processed all its signals. | |
Protected Attributes | |
FrameFifo * | framefifo |
Consume frames from here. | |
Protected Attributes inherited from Thread | |
std::string | name |
Name of the thread. | |
bool | has_thread |
true if thread has been started | |
bool | stop_requested |
bool | thread_joined |
std::mutex | start_mutex |
Mutex protecting start_condition. | |
std::condition_variable | start_condition |
Notified when the thread has been started. | |
std::mutex | mutex |
Mutex protecting the condition variable and signal queue. | |
std::condition_variable | condition |
Condition variable for the signal queue (triggered when all signals processed). Not necessarily used by all subclasses. | |
std::mutex | loop_mutex |
Protects thread's main execution loop (if necessary) | |
std::deque< SignalContext > | signal_fifo |
Signal queue (fifo). Redefine in child classes. | |
bool | loop |
Use this boolean to control if the main loop in Thread:run should exit. | |
int | core_id |
pthread_attr_t | thread_attr |
Thread attributes, pthread_* way. | |
cpu_set_t | cpuset |
pthread_t | internal_thread |
Additional Inherited Members | |
Protected Member Functions inherited from Thread | |
void | mainRun () |
Does the preRun, run, postRun sequence. | |
void | closeThread () |
Sends exit signal to the thread, calls join. This method blocks until thread has exited. Set Thread::has_thread to false. | |
Static Protected Member Functions inherited from Thread | |
static void * | mainRun_ (void *p) |
A demo thread for testing the producer/consumer module for fifos.
Consumer side.