SourcePro® 2024.1 |
SourcePro® API Reference Guide |
Base class that provides buffered producer-consumer synchronization semantics for exchanging decorated values between cooperating threads. More...
#include <rw/itc/RWTPCValBufferBaseDecorated.h>
Public Member Functions | |
virtual | ~RWTPCValBufferBaseDecorated (void) |
RWWaitStatus | peek (Type &result, unsigned long milliseconds) |
Type | peek (void) |
RWWaitStatus | read (Type &result, unsigned long milliseconds) |
Type | read (void) |
bool | tryPeek (Type &result) |
bool | tryRead (Type &result) |
bool | tryWrite (const Type &value) |
void | write (const Type &value) |
RWWaitStatus | write (const Type &value, unsigned long milliseconds) |
Additional Inherited Members | |
Protected Types inherited from RWTMonitor< RWMutexLock > | |
typedef RWTLockGuard< RWTMonitor< RWMutexLock > > | LockGuard |
typedef RWTTryLockGuard< RWTMonitor< RWMutexLock > > | TryLockGuard |
typedef RWTUnlockGuard< RWTMonitor< RWMutexLock > > | UnlockGuard |
Protected Member Functions inherited from RWTPCValBufferBase< Decorator > | |
virtual | ~RWTPCValBufferBase (void) |
RWWaitStatus | peek (Decorator &result, unsigned long milliseconds) |
Decorator | peek (void) |
RWWaitStatus | read (Decorator &result, unsigned long milliseconds) |
Decorator | read (void) |
bool | tryPeek (Decorator &result) |
bool | tryRead (Decorator &result) |
bool | tryWrite (const Decorator &value) |
void | write (const Decorator &value) |
RWWaitStatus | write (const Decorator &value, unsigned long milliseconds) |
virtual | ~RWPCBufferBase (void) |
bool | canRead (void) const |
bool | canWrite (void) const |
void | close (void) |
size_t | entries (void) const |
void | flush (void) |
size_t | getCapacity (void) const |
RWTFunctor< void()> | getCloseCallback (void) const |
RWTFunctor< void()> | getEmptyCallback (void) const |
RWTFunctor< void()> | getFullCallback (void) const |
RWTFunctor< void()> | getOpenCallback (void) const |
bool | isOpen (void) const |
void | open (void) |
size_t | setCapacity (size_t maxCapacity) |
void | setCloseCallback (const RWTFunctor< void()> &onCloseCallback) |
void | setEmptyCallback (const RWTFunctor< void()> &onEmptyCallback) |
void | setFullCallback (const RWTFunctor< void()> &onFullCallback) |
void | setOpenCallback (const RWTFunctor< void()> &onOpenCallback) |
Protected Member Functions inherited from RWTMonitor< RWMutexLock > | |
RWTMonitor (const RWTMonitor< RWMutexLock > &second) | |
RWTMonitor (RWStaticCtor) | |
RWTMonitor (void) | |
~RWTMonitor (void) | |
void | acquire (void) |
bool | isAcquired (void) const |
RWTMonitor< RWMutexLock > & | monitor (void) const |
RWMutexLock & | mutex (void) |
RWTMonitor< RWMutexLock > & | operator= (const RWTMonitor< RWMutexLock > &) |
void | release (void) |
bool | tryAcquire (void) |
RWTPCValBufferBaseDecorated is the base class for the family of classes that provides buffered producer-consumer synchronization semantics for exchanging decorated values between cooperating threads.
In the producer-consumer synchronization model, reader threads (consumers) are blocked while a buffer is empty, and writer threads (producers) are blocked while a buffer is full. A buffer is considered full when the number of unread entries equals or exceeds some user-specified maximum capacity.
The write operations provided by this class and its subclasses bind additional data items to each value prior to storing that value in an internal buffer. These additional data items are referred to as decorations, and are generally used to control the insertion or extraction process. Some examples of decorations include guard functors, instances, and priority values.
The template parameter Decorator
identifies the class that is used to encapsulate both the value and its decorations as a single object for storage in the internal buffer. The decorator classes used by subclasses to instantiate this class are intended for the Threads Module's internal use and are not documented as part of the public interface.
|
virtual |
Virtual destructor.
RWWaitStatus RWTPCValBufferBaseDecorated< Type, Decorator >::peek | ( | Type & | result, |
unsigned long | milliseconds ) |
Copies and returns the next available value stored in the buffer, where the availability and ordering of values is determined by the implementation supplied in derived classes.
If the buffer contains a value that is eligible for reading, this function copies that value into the instance passed as a reference, and returns a value of RW_THR_COMPLETED to indicate that the read succeeded. If the buffer is open and there are no values that are eligible for reading, or if the buffer is empty, this function blocks the calling thread until a value becomes available, or until the buffer is closed, or until the specified amount of time has passed. If no value becomes available within the specified amount of time, the function returns with a value of RW_THR_TIMEOUT.
If the buffer is closed while the calling thread is blocked and waiting within this function for a value to become available, the calling thread is unblocked and the function returns by throwing an RWTHRClosedException. If the buffer is both empty and closed when this function is called, it immediately returns by throwing an RWTHRClosedException.
Calling this function on an empty buffer may result in the invocation of the on-empty callback functor, if a valid one has been registered. The on-empty callback functor is guaranteed to execute only within a reader thread. Calling this function on an empty buffer results in the invocation of an on-empty callback functor under either of these scenarios:
Repeated attempts to read from an empty buffer does not result in repeated invocations of the callback functor. Once the empty buffer is written to, however, it resets the callback trigger. If the buffer again becomes empty, the first thread to attempt to read from it causes another invocation of the on-empty callback.
While this function guarantees to wait, if necessary, for a period of time equal to or greater than the specified number of milliseconds, this function cannot guarantee that the thread is actually scheduled for execution at the end of the time-out period. The function cannot prevent the on-empty callback functor, if executed, from indirectly blocking the caller for an indefinite period of time.
This function takes two parameters. The parameter result is a reference to an instance of the type used to instantiate this template class. The result, if any, is copied into this instance using its assignment operator. The parameter milliseconds is an unsigned long
value that specifies the maximum number of milliseconds to wait for the operation to complete.
Type RWTPCValBufferBaseDecorated< Type, Decorator >::peek | ( | void | ) |
Copies and returns the next available value stored in the buffer, where the availability and ordering of values is determined by the implementation supplied in derived classes. The value is of the type used to instantiate this template class.
If the buffer contains a value that is eligible for reading, this function copies and returns that value even if the buffer is closed. If the buffer is open and there are no values that are eligible for reading, or if the buffer is empty, this function blocks the calling thread until a value becomes available or until the buffer is closed. If the buffer is closed while the calling thread is blocked and waiting within this function for a value to become available, the calling thread is unblocked and the function returns by throwing an RWTHRClosedException. If the buffer is both empty and closed when this function is called, it immediately returns by throwing an RWTHRClosedException.
Calling this function on an empty buffer may result in the invocation of the on-empty callback functor, if a valid one has been registered. The on-empty callback functor is guaranteed to execute only within a reader thread. Calling this function on an empty buffer results in the invocation of an on-empty callback functor under either of these scenarios:
Repeated attempts to read from an empty buffer does not result in repeated invocations of the callback functor. Once the empty buffer is written to, however, it resets the callback trigger. If the buffer again becomes empty, the first thread to attempt to read from it causes another invocation of the on-empty callback.
RWWaitStatus RWTPCValBufferBaseDecorated< Type, Decorator >::read | ( | Type & | result, |
unsigned long | milliseconds ) |
Removes and returns the next available value stored in the buffer, where the availability and ordering of values is determined by the implementation supplied in derived classes.
If the buffer contains a value that is eligible for reading, this function removes that value, copies it into the instance passed as a reference, and returns a value of RW_THR_COMPLETED to indicate that the read succeeded. If the buffer is open and there are no values that are eligible for reading, or if the buffer is empty, this function blocks the calling thread until a value becomes available, or until the buffer is closed, or until the specified amount of time passes. If no value becomes available within the specified amount of time, the function returns with value of RW_THR_TIMEOUT.
If the buffer is closed while the calling thread is blocked and waiting within this function for a value to become available, the calling thread is unblocked and the function returns by throwing an RWTHRClosedException. If the buffer is both empty and closed when this function is called, the function immediately returns by throwing an RWTHRClosedException.
Calling this function on an empty buffer may result in the invocation of the on-empty callback functor, if a valid one has been registered. The on-empty callback functor is guaranteed to execute only within a reader thread. Calling this function on an empty buffer results in the invocation of an on-empty callback functor under either of these scenarios:
Repeated attempts to read from an empty buffer does not result in repeated invocations of the callback functor. Once the empty buffer is written to, however, it resets the callback trigger. If the buffer again becomes empty, the first thread to attempt to read from it causes another invocation of the on-empty callback.
While this function guarantees to wait, if necessary, for a period time equal to or greater than the specified number of milliseconds, it cannot guarantee that the thread is actually scheduled for execution at the end of the time-out period. It cannot prevent the on-empty callback functor, if executed, from indirectly blocking the caller for an indefinite period of time.
This function takes two parameters. The parameter result is a reference to an instance of the type used to instantiate this template class. The result, if any, is copied into this instance using its assignment operator. The parameter milliseconds is an unsigned long
value that specifies the maximum number of milliseconds to wait for the operation to complete.
Type RWTPCValBufferBaseDecorated< Type, Decorator >::read | ( | void | ) |
Removes and returns the next available value stored in the buffer, where the availability and ordering of values is determined by the implementation supplied in derived classes. The value is of the type used to instantiate this template class.
If the buffer contains a value that is eligible for reading, this function removes and returns that value even if the buffer is closed. If the buffer is open and there are no values that are eligible for reading, or if the buffer is empty, this function blocks the calling thread until a value becomes available or until the buffer is closed.
If the buffer is closed while the calling thread is blocked and waiting within this function for a value to become available, the calling thread is unblocked and the function returns by throwing an RWTHRClosedException. If the buffer is both empty and closed when this function is called, the function immediately returns by throwing an RWTHRClosedException.
Calling this function on an empty buffer may result in the invocation of the on-empty callback functor, if a valid one has been registered. The on-empty callback functor is guaranteed to execute only within a reader thread. Calling this function on an empty buffer results in the invocation of an on-empty callback functor under either of these scenarios:
Repeated attempts to read from an empty buffer does not result in repeated invocations of the callback functor. Once the empty buffer is written to, however, it resets the callback trigger. If the buffer again becomes empty, the first thread to attempt to read from it causes another invocation of the on-empty callback.
bool RWTPCValBufferBaseDecorated< Type, Decorator >::tryPeek | ( | Type & | result | ) |
Copies and returns the next immediately available value stored in the buffer, where the availability and ordering of values is determined by the implementation supplied in derived classes.
If the buffer contains a value that is eligible for reading, this function copies that value into the instance passed as a reference, and returns a value of true
to indicate that the read succeeded. If the buffer is open and there are no values that are eligible for reading, or if the buffer is empty, this function immediately returns false
to indicate that the read was unsuccessful. If the buffer is both empty and closed, this function immediately returns by throwing an RWTHRClosedException.
Calling this function on an empty buffer may result in the invocation of the on-empty callback functor, if a valid one has been registered. The on-empty callback functor is guaranteed to execute only within a reader thread. Calling this function on an empty buffer results in the invocation of an on-empty callback functor under either of these scenarios:
Repeated attempts to read from an empty buffer does not result in repeated invocations of the callback functor. Once the empty buffer is written to, however, it resets the callback trigger. If the buffer again becomes empty, the first thread to attempt to read from it causes another invocation of the on-empty callback.
While this function guarantees not to block the caller if there are no readable entries, it cannot prevent the on-empty callback functor, if executed, from indirectly blocking the caller.
This function takes the parameter result, which is a reference to an instance of the type used to instantiate this template class. The result, if any, is copied into this instance using its assignment operator.
bool RWTPCValBufferBaseDecorated< Type, Decorator >::tryRead | ( | Type & | result | ) |
Removes and returns the next immediately available value stored in the buffer, where the availability and ordering of values is determined by the implementation supplied in derived classes.
If the buffer contains a value that is eligible for reading, this function removes that value, copies it into the instance passed as a reference, and returns a value of true
to indicate that the read succeeded. If the buffer is open and there are no values that are eligible for reading, or if the buffer is empty, this function immediately returns a value of false
to indicate that the read was unsuccessful. If the buffer is both empty and closed, this function immediately returns by throwing an RWTHRClosedException.
Calling this function on an empty buffer may result in the invocation of the on-empty callback functor, if a valid one has been registered. The on-empty callback functor is guaranteed to execute only within a reader thread. Calling this function on an empty buffer results in the invocation of an on-empty callback functor under either of these scenarios:
Repeated attempts to read from an empty buffer does not result in repeated invocations of the callback functor. Once the empty buffer is written to, however, it resets the callback trigger. If the buffer again becomes empty, the first thread to attempt to read from it causes another invocation of the on-empty callback.
While this function guarantees not to block the caller if there are no readable entries, it cannot prevent the on-empty callback functor, if executed, from indirectly blocking the caller.
This function takes the parameter result, which is a reference to an instance of the type used to instantiate this template class. The result, if any, is copied into this instance using its assignment operator.
bool RWTPCValBufferBaseDecorated< Type, Decorator >::tryWrite | ( | const Type & | value | ) |
Inserts a decorated value into the buffer at a position that is determined by the implementation supplied in derived classes, but only if the value may be written immediately; in other words, only if there is sufficient free capacity. The value is decorated using the defaults defined by the implementation supplied in derived classes.
If the buffer is open and has sufficient capacity to hold another value, this function inserts the value, and returns a value of true
to indicate that the write succeeded. If the buffer is open and full, this function immediately returns a value of false
to indicate that the write was unsuccessful. If the buffer is closed, this function immediately returns by throwing an RWTHRClosedException.
Calling this function on a full buffer may result in the invocation of the on-full callback functor, if a valid one has been registered. The on-full callback functor is guaranteed to execute only within a writer thread. Calling this function on a full buffer results in the invocation of an on-full callback functor under either of these scenarios:
Repeated attempts to write to a full buffer does not result in repeated invocations of the callback functor. Once the full buffer is read from, however, it resets the callback trigger. If the buffer again becomes full, the first thread to attempt to write to it causes another invocation of the on-full callback.
While this function guarantees not to block the caller if the buffer is full, this function cannot prevent the on-full callback functor, if executed, from indirectly blocking the caller.
This function takes the parameter value, which is a const
reference to an instance of the type used to instantiate this template class.
void RWTPCValBufferBaseDecorated< Type, Decorator >::write | ( | const Type & | value | ) |
Inserts a decorated value into the buffer at a position that is determined by the implementation supplied in derived classes. The value is decorated using the defaults defined by the implementation supplied in derived classes.
If the buffer is open and has sufficient capacity to hold another value, this function inserts the value. If the buffer is open and yet full, this function blocks the calling thread until the buffer is no longer full (because another thread or threads have read values or have changed the maximum capacity), or until the buffer is closed.
If the buffer is closed while the calling thread is blocked and waiting within this function for room to write, the calling thread is unblocked and the function returns by throwing an RWTHRClosedException.
If the buffer is already closed when this function is called, the function immediately returns by throwing an RWTHRClosedException.
Calling this function on a full buffer may result in the invocation of the on-full callback functor, if a valid one has been registered. The on-full callback functor is guaranteed to execute only within a writer thread. Calling this function on a full buffer results in the invocation of an on-full callback functor under either of these scenarios:
Repeated attempts to write to a full buffer does not result in repeated invocations of the callback functor. Once the full buffer is read from, however, it resets the callback trigger. If the buffer again becomes full, the first thread to attempt to write to it causes another invocation of the on-full callback.
RWWaitStatus RWTPCValBufferBaseDecorated< Type, Decorator >::write | ( | const Type & | value, |
unsigned long | milliseconds ) |
Inserts a decorated value into the buffer at a position that is determined by the implementation supplied in derived classes. The value is decorated using the defaults defined by the implementation supplied in derived classes.
If the buffer is open and has sufficient capacity to hold another value, this function inserts the value, and returns a value of RW_THR_COMPLETED to indicate that the write succeeded. If the buffer is open and full, this function blocks the calling thread until the buffer is no longer full (because another thread or threads have read values or have changed the maximum capacity), or until the buffer is closed, or until the specified amount of time has passes. If sufficient space does not become available within the specified amount of time, the function returns a value of RW_THR_TIMEOUT.
If the buffer is closed while the calling thread is blocked and waiting within this function for room to write, the calling thread is unblocked and the function returns by throwing an RWTHRClosedException. If the buffer is already closed when this function is called, the function immediately returns by throwing an RWTHRClosedException.
Calling this function on a full buffer may result in the invocation of the on-full callback functor, if a valid one has been registered. The on-full callback functor is guaranteed to execute only within a writer thread. Calling this function on a full buffer results in the invocation of an on-full callback functor under either of these scenarios:
Repeated attempts to write to a full buffer does not result in repeated invocations of the callback functor. Once the full buffer is read from, however, it resets the callback trigger. If the buffer again becomes full, the first thread to attempt to write to it causes another invocation of the on-full callback.
While this function guarantees to wait, if necessary, for a time equal to or greater than the specified number of milliseconds, it cannot guarantee that the thread is actually scheduled for execution at the end of the time-out period. It cannot prevent the on-full callback functor, if executed, from indirectly blocking the caller for an indefinite period of time.
This function takes two parameters. The parameter value is a const
reference to an instance of the type used to instantiate this template class. The parameter milliseconds is an unsigned long
value that specifies the maximum number of milliseconds to wait for the operation to complete.
Copyright © 2024 Rogue Wave Software, Inc., a Perforce company. All Rights Reserved. |