RWTPCValBufferBaseDecorated<Type,Decorator>

Module:  Threads   Package:  Interthread Communication

RWTPCValBufferBaseDecorated<Type,Decorator>
   (protected) RWTPCValBufferBase<Decorator>

• Local Index
• Header File
• Description
• Public Destructor
• Inherited Functions
• Public Member Functions
• See Also

Members

peek() read()

tryPeek() tryRead()

tryWrite() write()

~RWTPCValBufferBaseDecorated()

#include <rw/itc/RWTPCValBufferBaseDecorated.h> 

RWTPCValBufferBaseDecorated<Type,Decorator> is the base class for the family of classes that provide 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
~RWTPCValBufferBaseDecorated();

Virtual destructor.

The following functions are inherited from the protected base class instantiation, RWTPCValBufferBase<Decorator>. They are access-adjusted to make them public in this class.

RWTPCValBufferBase<Decorator>::setCapacity;
RWTPCValBufferBase<Decorator>::getCapacity;
RWTPCValBufferBase<Decorator>::open;
RWTPCValBufferBase<Decorator>::isOpen;
RWTPCValBufferBase<Decorator>::close;
RWTPCValBufferBase<Decorator>::canRead;
RWTPCValBufferBase<Decorator>::canWrite;
RWTPCValBufferBase<Decorator>::entries;
RWTPCValBufferBase<Decorator>::flush;
RWTPCValBufferBase<Decorator>::getEmptyCallback;
RWTPCValBufferBase<Decorator>::setEmptyCallback;
RWTPCValBufferBase<Decorator>::getFullCallback;
RWTPCValBufferBase<Decorator>::setFullCallback;
RWTPCValBufferBase<Decorator>::getOpenCallback;
RWTPCValBufferBase<Decorator>::setOpenCallback;
RWTPCValBufferBase<Decorator>::getCloseCallback;
RWTPCValBufferBase<Decorator>::setCloseCallback;

Type 
peek();

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, then 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 was registered. The on-empty callback functor is guaranteed to execute only within a reader thread. Calling this function on an empty buffer will result in the invocation of an on-empty callback functor under either of these scenarios:

• The calling thread is waiting on an empty buffer when an on-empty callback is registered.

• The calling thread is the first to attempt reading from an empty buffer in which an on-empty callback was previously registered.

Repeated attempts to read from an empty buffer will not result in repeated invocations of the callback functor. Once the empty buffer is written to, however, it resets the callback trigger; should the buffer again become empty, the first thread to attempt to read will cause another invocation of the on-empty callback.

RWWaitStatus
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 was registered. The on-empty callback functor is guaranteed to execute only within a reader thread. Calling this function on an empty buffer will result in the invocation of an on-empty callback functor under either of these scenarios:

• The calling thread is waiting on an empty buffer when an on-empty callback is registered.

• The calling thread is the first to attempt reading from an empty buffer in which an on-empty callback was previously registered.

Repeated attempts to read from an empty buffer will not result in repeated invocations of the callback functor. Once the empty buffer is written to, however, it resets the callback trigger; should the buffer again become empty, the first thread to attempt to read will cause 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
read();

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 was registered. The on-empty callback functor is guaranteed to execute only within a reader thread. Calling this function on an empty buffer will result in the invocation of an on-empty callback functor under either of these scenarios:

• The calling thread is waiting on an empty buffer when an on-empty callback is registered.

• The calling thread is the first to attempt reading from an empty buffer in which an on-empty callback was previously registered.

Repeated attempts to read from an empty buffer will not result in repeated invocations of the callback functor. Once the empty buffer is written to, however, it resets the callback trigger; should the buffer again become empty, the first thread to attempt to read will cause another invocation of the on-empty callback.

RWWaitStatus
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 was registered. The on-empty callback functor is guaranteed to execute only within a reader thread. Calling this function on an empty buffer will result in the invocation of an on-empty callback functor under either of these scenarios:

• The calling thread is waiting on an empty buffer when an on-empty callback is registered.

• The calling thread is the first to attempt reading from an empty buffer in which an on-empty callback was previously registered.

Repeated attempts to read from an empty buffer will not result in repeated invocations of the callback functor. Once the empty buffer is written to, however, it resets the callback trigger; should the buffer again become empty, the first thread to attempt to read will cause 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.

bool
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 was registered. The on-empty callback functor is guaranteed to execute only within a reader thread. Calling this function on an empty buffer will result in the invocation of an on-empty callback functor under either of these scenarios:

• The calling thread is waiting on an empty buffer when an on-empty callback is registered.

• The calling thread is the first to attempt reading from an empty buffer in which an on-empty callback was previously registered.

Repeated attempts to read from an empty buffer will not result in repeated invocations of the callback functor. Once the empty buffer is written to, however, it resets the callback trigger; should the buffer again become empty, the first thread to attempt to read will cause 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
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 was registered. The on-empty callback functor is guaranteed to execute only within a reader thread. Calling this function on an empty buffer will result in the invocation of an on-empty callback functor under either of these scenarios:

• The calling thread is waiting on an empty buffer when an on-empty callback is registered.

• The calling thread is the first to attempt reading from an empty buffer in which an on-empty callback was previously registered.

Repeated attempts to read from an empty buffer will not result in repeated invocations of the callback functor. Once the empty buffer is written to, however, it resets the callback trigger; should the buffer again become empty, the first thread to attempt to read will cause 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 
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 was registered. The on-full callback functor is guaranteed to execute only within a writer thread. Calling this function on a full buffer will result in the invocation of an on-full callback functor under either of these scenarios:

• The calling thread is waiting on an full buffer when an on-full callback is registered.

• The calling thread is the first to attempt writing to a full buffer in which an on-full callback was previously registered.

Repeated attempts to write to a full buffer will not result in repeated invocations of the callback functor. Once the full buffer is read from, however, it resets the callback trigger; should the buffer again become full, the first thread to attempt to write will cause 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 
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, then 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 was registered. The on-full callback functor is guaranteed to execute only within a writer thread. Calling this function on a full buffer will result in the invocation of an on-full callback functor under either of these scenarios:

• The calling thread is waiting on an full buffer when an on-full callback is registered.

• The calling thread is the first to attempt writing to a full buffer in which an on-full callback was previously registered.

Repeated attempts to write to a full buffer will not result in repeated invocations of the callback functor. Once the full buffer is read from, however, it resets the callback trigger; should the buffer again become full, the first thread to attempt to write will cause another invocation of the on-full callback.

RWWaitStatus 
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 was registered. The on-full callback functor is guaranteed to execute only within a writer thread. Calling this function on a full buffer will result in the invocation of an on-full callback functor under either of these scenarios:

• The calling thread is waiting on an full buffer when an on-full callback is registered.

• The calling thread is the first to attempt writing to a full buffer in which an on-full callback was previously registered.

Repeated attempts to write to a full buffer will not result in repeated invocations of the callback functor. Once the full buffer is read from, however, it resets the callback trigger; should the buffer again become full, the first thread to attempt to write will cause 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.

RWTPCValBufferBase<Type>,RWTPCValBufferBaseGuarded<Type,GuardDecorator>, RWTPCValBufferBasePrioritized<Type,PriorityDecorator>

© Copyright Rogue Wave Software, Inc. All Rights Reserved.
Rogue Wave and SourcePro are registered trademarks of Rogue Wave Software, Inc. in the United States and other countries. All other trademarks are the property of their respective owners.
Contact Rogue Wave about documentation or support issues.