#include <VrMultiTask.h>
Public Member Functions | |
VrMultiTask () | |
VrMultiTask (int n_threads) | |
~VrMultiTask () | |
void | add (VrSigProc *s) |
void | start () |
one time call to start everything | |
void | stop () |
one time call to stop everything | |
void | process () |
one iteration of signal processing loop | |
int | isStarted () |
void | schedule () |
Figures out work to be done and then does it. | |
void | startTimer () |
double | elapsedTime () |
Private Attributes | |
VrSigProc ** | sinks |
all sinks (connected or not) | |
int | numberSinks |
total number of sinks | |
VrSigProc ** | goodSinks |
connected sinks | |
int | numSinks |
number of connected sinks | |
int | numThreads |
volatile int | stopFlag |
timeval | initialTime |
|
|
|
|
|
|
|
|
|
|
|
|
|
one iteration of signal processing loop
|
|
Figures out work to be done and then does it. Using markData schedule figures out what data needs to be computed. When this phase it complete, compute is called to geneate the data. Threads MUST acquire the mutex _before_ calling schedule() |
|
one time call to start everything
|
|
|
|
one time call to stop everything
|
|
connected sinks
|
|
|
|
total number of sinks
|
|
number of connected sinks
|
|
|
|
all sinks (connected or not)
|
|
|