template<class ATOMIC_OP, class MUTEX, class CONDITION, class THREADUTIL>
class bslmt::FastPostSemaphoreImpl< ATOMIC_OP, MUTEX, CONDITION, THREADUTIL >
This class implements a semaphore type, optimized for post
, for thread synchronization.
See bslmt_fastpostsemaphoreimpl
template<class ATOMIC_OP , class MUTEX , class CONDITION , class THREADUTIL >
Disable waiting on this semaphore. All subsequent invocations of wait
, tryWait
, and timedWait
will fail immediately. All blocked invocations of wait
and timedWait
will fail immediately. If the semaphore is initially disabled, this call has no effect.
template<class ATOMIC_OP , class MUTEX , class CONDITION , class THREADUTIL >
Return an odd value if this semaphore is wait disabled, and an even value otherwise. The returned value can be used to detect a rapid short sequence of disable
and enable
invocations by comparing the value returned by getDisabledState
before and after the sequence. For example, for any initial state of a semphore instance obj
:
int state = obj.getDisabledState();
obj.disable();
obj.enable();
ASSERT(state != obj.getDisabledState());
This functionality is useful in higher-level components to determine if this semaphore was disabled during an operation.
template<class ATOMIC_OP , class MUTEX , class CONDITION , class THREADUTIL >
void bslmt::FastPostSemaphoreImpl< ATOMIC_OP, MUTEX, CONDITION, THREADUTIL >::postWithRedundantSignal |
( |
int |
value, |
|
|
int |
available, |
|
|
int |
blocked |
|
) |
| |
|
inline |
Atomically increase the count of this semaphore by the specified value
. If the resources available to this semaphore is greater than or equal to the specified available
and the number of threads blocked in this semaphore is greater than or equal to the specified blocked
, always send a signal to potentially wake a waiting thread (even if the signal should not be needed). The behavior is undefined unless value > 0
. Note that this method is provided to help mitigate issues in the implementation of underlying synchronization primitives.
template<class ATOMIC_OP , class MUTEX , class CONDITION , class THREADUTIL >
If the count of this semaphore is positive, reduce the count by the lesser of the count and the specified maximumToTake
and return the magnitude of the change to the count. Otherwise, do nothing and return 0.
template<class ATOMIC_OP , class MUTEX , class CONDITION , class THREADUTIL >
If this semaphore is initially disabled, or becomes disabled while blocking, return e_DISABLED
with no effect on the count. Otherwise, block until the count of this semaphore is a positive value or the specified absTime
timeout expires. If the count of this semaphore is a positive value, return 0 and atomically decrement the count. If the absTime
timeout expires, return e_TIMED_OUT
with no effect on the count. Return e_FAILED
if an error occurs. absTime
is an absolute time represented as an interval from some epoch, which is determined by the clock indicated at construction (see {Supported Clock-Types} in the component documentation).
template<class ATOMIC_OP , class MUTEX , class CONDITION , class THREADUTIL >
If this semaphore is initially disabled, return e_DISABLED
with no effect on the count. Otherwise, if the count of this semaphore is a positive value, return 0 and atomically decrement the count. If this semaphore is not disabled and the count of this semaphore is not a positive value, return e_WOULD_BLOCK
with no effect on the count.
template<class ATOMIC_OP , class MUTEX , class CONDITION , class THREADUTIL >
If this semaphore is initially disabled, or becomes disabled while blocking, return e_DISABLED
with no effect on the count. Otherwise, block until the count of this semaphore is a positive value, return 0 and atomically decrement the count. Return e_FAILED
if an error occurs.