PTLib
Version 2.18.8
|
This class defines a thread synchronisation object. More...
#include <syncpoint.h>
Public Member Functions | |
PSyncPoint () | |
Create a new sync point. More... | |
PSyncPoint (const PSyncPoint &) | |
virtual void | Wait () |
Block until the synchronisation object is available. More... | |
virtual PBoolean | Wait (const PTimeInterval &timeout) |
Block, for a time, until the synchronisation object is available. More... | |
virtual void | Signal () |
Signal that the synchronisation object is available. More... | |
![]() | |
PSync () | |
virtual bool | InstrumentedWait (const PTimeInterval &timeout, const PDebugLocation &) |
As for Wait() but with location of call for instrumentation. Mostly used internally. More... | |
virtual void | InstrumentedSignal (const PDebugLocation &) |
As for Signal() but with location of call for instrumentation. Mostly used internally. More... | |
![]() | |
__inline unsigned | GetTraceContextIdentifier () const |
Get PTRACE context identifier. More... | |
__inline void | SetTraceContextIdentifier (unsigned id) |
__inline void | SetTraceContextIdentifier (const PObject &obj) |
__inline void | SetTraceContextIdentifier (const PObject *obj) |
__inline void | CopyTraceContextIdentifier (PObject &obj) const |
__inline void | CopyTraceContextIdentifier (PObject *obj) const |
virtual | ~PObject () |
__inline const char * | GetClass () const |
__inline bool | IsClass (const char *name) const |
__inline const PObject * | PTraceObjectInstance () const |
virtual PObject * | Clone () const |
Create a copy of the class on the heap. More... | |
template<class CLS > | |
CLS * | CloneAs () const |
As for Clone() but converts to specified type. More... | |
virtual PINDEX | HashFunction () const |
This function yields a hash value required by the PDictionary class. More... | |
virtual Comparison | Compare (const PObject &obj) const |
Compare the two objects and return their relative rank. More... | |
virtual Comparison | CompareObjectMemoryDirect (const PObject &obj) const |
Determine the byte wise comparison of two objects. More... | |
bool | operator== (const PObject &obj) const |
Compare the two objects. More... | |
bool | operator!= (const PObject &obj) const |
Compare the two objects. More... | |
bool | operator< (const PObject &obj) const |
Compare the two objects. More... | |
bool | operator> (const PObject &obj) const |
Compare the two objects. More... | |
bool | operator<= (const PObject &obj) const |
Compare the two objects. More... | |
bool | operator>= (const PObject &obj) const |
Compare the two objects. More... | |
virtual void | PrintOn (ostream &strm) const |
Output the contents of the object to the stream. More... | |
virtual void | ReadFrom (istream &strm) |
Input the contents of the object from the stream. More... | |
Additional Inherited Members | |
![]() | |
enum | Comparison { LessThan = -1, EqualTo = 0, GreaterThan = 1 } |
Result of the comparison operation performed by the Compare() function. More... | |
![]() | |
static __inline void | CopyTraceContextIdentifier (PObject &to, const PObject &from) |
static __inline void | CopyTraceContextIdentifier (PObject &to, const PObject *from) |
static __inline void | CopyTraceContextIdentifier (PObject *to, const PObject &from) |
static __inline void | CopyTraceContextIdentifier (PObject *to, const PObject *from) |
static __inline const char * | Class () |
static __inline const PObject * | PTraceObjectInstance (const char *) |
static __inline const PObject * | PTraceObjectInstance (const PObject *obj) |
template<typename T > | |
static Comparison | Compare2 (T v1, T v2) |
Compare two types, returning Comparison type. More... | |
static Comparison | InternalCompareObjectMemoryDirect (const PObject *obj1, const PObject *obj2, PINDEX size) |
Internal function caled from CompareObjectMemoryDirect() More... | |
![]() | |
PObject () | |
Constructor for PObject, made protected so cannot ever create one on its own. More... | |
![]() | |
unsigned | m_traceContextIdentifier |
This class defines a thread synchronisation object.
This form of semaphore is used to indicate an event has occurred. A thread may block on the sync point and wait until another thread signals that it may continue. eg:
... thread one
while (condition) {
sync.Wait();
do_something();
}
... thread 2
do_something_else();
sync.Signal(); // At this point thread 1 wake up and does something.
do_yet_more();
Note that events are boolean in nature. If "thread one" is not waiting on the event, multiple calls to Signal() are ignored, thread one will only exit the Wait() call a single time once it gets there. Similarly, if multiple threads are waiting on the event, only one thread will be released. As you cannot know which thread will be released this mode of use is not recommended.
PSyncPoint::PSyncPoint | ( | ) |
Create a new sync point.
PSyncPoint::PSyncPoint | ( | const PSyncPoint & | ) |
|
virtual |
Signal that the synchronisation object is available.
Implements PSync.
Reimplemented in PSyncPointAck.
Referenced by PSyncQueue< PQueuedThreadPool::QueuedWorkerThread::QueuedWork >::Dequeue().
|
virtual |
Block until the synchronisation object is available.
Implements PSync.
Referenced by PSyncQueue< PQueuedThreadPool::QueuedWorkerThread::QueuedWork >::Close(), and PSyncQueue< PQueuedThreadPool::QueuedWorkerThread::QueuedWork >::Drain().
|
virtual |
Block, for a time, until the synchronisation object is available.
Implements PSync.