RWTPCValStackGuardedPrioritized< Type > Class Template Reference

Last-in-first-out (LIFO) stack that provides producer-consumer synchronization semantics for exchanging guarded and prioritized values between cooperating threads. More...

#include <rw/itc/RWTPCValStackGuardedPrioritized.h>

Inheritance diagram for RWTPCValStackGuardedPrioritized< Type >:

Public Member Functions
	RWTPCValStackGuardedPrioritized (size_t maxCapacity)
	RWTPCValStackGuardedPrioritized (size_t maxCapacity, bool isOpen)
	RWTPCValStackGuardedPrioritized (void)
	~RWTPCValStackGuardedPrioritized (void)
Public Member Functions inherited from RWTPCValBufferBaseGuardedPrioritized< Type, RWTGuardAndPriorityDecorator< Type > >
virtual	~RWTPCValBufferBaseGuardedPrioritized (void)
bool	tryWrite (const Type &value)
bool	tryWrite (const Type &value, const RWTFunctor< bool()> &guard)
bool	tryWrite (long priority, const Type &value)
bool	tryWrite (long priority, const Type &value, const RWTFunctor< bool()> &guard)
void	write (const Type &value)
void	write (const Type &value, const RWTFunctor< bool()> &guard)
RWWaitStatus	write (const Type &value, const RWTFunctor< bool()> &guard, unsigned long milliseconds)
RWWaitStatus	write (const Type &value, unsigned long milliseconds)
void	write (long priority, const Type &value)
void	write (long priority, const Type &value, const RWTFunctor< bool()> &guard)
RWWaitStatus	write (long priority, const Type &value, const RWTFunctor< bool()> &guard, unsigned long milliseconds)
RWWaitStatus	write (long priority, const Type &value, unsigned long milliseconds)
Public Member Functions inherited from RWTPCValBufferBaseGuarded< Type, RWTGuardAndPriorityDecorator< Type > >
virtual	~RWTPCValBufferBaseGuarded (void)
RWWaitStatus	peek (Type &result, unsigned long milliseconds)
Type	peek (void)
RWWaitStatus	read (Type &result, unsigned long milliseconds)
Type	read (void)
bool	tryPeek (Type &value)
bool	tryRead (Type &value)
bool	tryWrite (const Type &value, const RWTFunctor< bool()> &guard)
void	write (const Type &value, const RWTFunctor< bool()> &guard)
RWWaitStatus	write (const Type &value, const RWTFunctor< bool()> &guard, unsigned long milliseconds)
Public Member Functions inherited from RWTPCValBufferBaseDecorated< Type, RWTGuardAndPriorityDecorator< Type > >
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)
Public Member Functions inherited from RWTPCValBufferBasePrioritized< Type, RWTGuardAndPriorityDecorator< Type > >
virtual	~RWTPCValBufferBasePrioritized (void)
bool	tryWrite (long priority, const Type &value)
void	write (long priority, const Type &value)
RWWaitStatus	write (long priority, 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< RWTGuardAndPriorityDecorator< Type > >
virtual	~RWTPCValBufferBase (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)
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)

Detailed Description

template<class Type>
class RWTPCValStackGuardedPrioritized< Type >

RWTPCValStackGuardedPrioritized is a last-in-first-out (LIFO) stack that provides producer-consumer synchronization semantics for exchanging guarded and prioritized values between cooperating threads.

In the producer-consumer synchronization model, reader threads (consumers) are blocked while the stack is empty, and writer threads (producers) are blocked while the stack is full. The stack is considered full when the number of unread entries equals or exceeds some user-specified maximum capacity.

The write operations inherited by this class bind a guard functor and priority value to each data value prior to storing that value in an internal buffer. The guard functor is used during read operations to determine whether the associated value is currently eligible for retrieval from the buffer. The priority value is used during write operations to determine a value's insertion point within the stack, such that the set of unread values will be retrieved in priority order when they are eventually read from the stack. A new value is retrieved before any previously inserted values of the same priority, except when the retrieval of the newer values is prohibited by their guard functors.

Example

See the example given under RWTPCValQueueGuardedPrioritized.

Constructor & Destructor Documentation

RWTPCValStackGuardedPrioritized() [1/3]

template<class Type >

RWTPCValStackGuardedPrioritized< Type >::RWTPCValStackGuardedPrioritized ( void )

inline

Constructs a value-based, guarded, prioritized, producer-consumer stack instance.

The stack is open on construction and enforces no limit on the number of items in the stack.

RWTPCValStackGuardedPrioritized() [2/3]

template<class Type >

RWTPCValStackGuardedPrioritized< Type >::RWTPCValStackGuardedPrioritized ( size_t maxCapacity )

inline

Constructs a value-based, guarded, prioritized, producer-consumer stack instance.

The parameter maxCapacity specifies the maximum number of unread entries to allow to accumulate within the stack. Once the number of entries in the stack equals this number, any thread attempting to write an additional entry is blocked until an entry is removed by a read() operation, or until the capacity is increased. A capacity of zero is used to indicate that the stack has no size limit other than that imposed by memory limitations, and that all write() operations should complete without blocking.

The stack is open on construction.

RWTPCValStackGuardedPrioritized() [3/3]

template<class Type >

RWTPCValStackGuardedPrioritized< Type >::RWTPCValStackGuardedPrioritized ( size_t maxCapacity, bool isOpen )

inline

Constructs a value-based, guarded, prioritized, producer-consumer stack instance.

The parameter maxCapacity specifies the maximum number of unread entries to allow to accumulate within the stack. Once the number of entries in the stack equals this number, any thread attempting to write an additional entry is blocked until an entry is removed by a read() operation, or until the capacity is increased. A capacity of zero is used to indicate that the stack has no size limit other than that imposed by memory limitations, and that all write() operations should complete without blocking.

The parameter isOpen is a bool value that specifies whether the stack should be initialized in the open state, true, or the closed state, false.

~RWTPCValStackGuardedPrioritized()

template<class Type >

RWTPCValStackGuardedPrioritized< Type >::~RWTPCValStackGuardedPrioritized ( void )

inline

Destructor.