Queue of tasks.
More...
#include <JobQueue.h>
|
U32 | workers (void) const |
|
void | post (T job) |
|
void | post (T first_job, T last_job) |
|
BWORD | take (T &job) |
|
void | waitForJob (T &job) |
|
void | deliver (T job) |
|
BWORD | acceptDelivery (T &job) |
|
void | waitForDelivery (T &job) |
|
BWORD | synchronize (BWORD a_supervised=FALSE) |
| waits until all threads call sync More...
|
|
void | relayException (const Exception &a_rException) |
|
void | resolveException (void) |
|
Public Member Functions inherited from fe::Handled< JobQueue< T > > |
const hp< JobQueue< T > > & | getHandle (void) const |
| Get a safe handle to this object. More...
|
|
virtual I32 | protection (void) const |
|
virtual void | protect (void) |
|
virtual void | unprotect (void) |
|
virtual Protectable * | clone (Protectable *pInstance=NULL) |
|
virtual void | acquire (void) |
| Increment the reference count. More...
|
|
virtual void | acquire (int &rCount) |
| Increment the reference count (and get the count) More...
|
|
virtual void | release (void) |
| Decrement the reference count. More...
|
|
virtual void | abandon (void) |
| Decrement the reference count. More...
|
|
int | count (void) const |
| Return the count of references. More...
|
|
void | setName (const String &) |
|
void | trackReference (void *pReference, String what) |
|
void | untrackReference (void *pReference) |
|
void | registerRegion (void *pT, U32 bytes) |
|
|
RecursiveMutex | m_jobMonitor |
|
RecursiveMutex | m_workerMonitor |
|
RecursiveMutex::Condition | m_jobAvailable |
|
RecursiveMutex::Condition | m_workerDelivered |
|
std::queue< T > | m_posted |
|
std::queue< T > | m_delivered |
|
RecursiveMutex | m_barrierMonitor |
|
RecursiveMutex::Condition | m_barrierHit |
|
U32 | m_barrierCount |
|
U32 | m_barrierMet |
|
Exception * | m_pException |
|
template<typename T>
class fe::ext::JobQueue< T >
Queue of tasks.
◆ synchronize()
waits until all threads call sync
Returns true to exactly one of the threads.
The documentation for this class was generated from the following file: