RWGuardedRunnableQueueRWTPCValQueue<Type>
#include <rw/thread/RWGuardedRunnableQueue.h>
RWGuardedRunnableQueue is a producer-consumer queue specialized for Runnables. It will only de-queue an RWRunnable if it has an associated guard that evaluates to TRUE, or if there is no associated guard. This class is used internally by RWRunnableServer. It should not, in general, be used by users of the library.
typedef RWTFunctorR0<RWBoolean> RWRunnableGuard;
RWGuardedRunnableQueue(size_t,maxEntries=0);
Constructs an RWGuardedRunnableQueue.
RWRunnable readReadyRunnable(void);
De-queues the next runnable that is ready for execution.
RWRunnable readRunnable(void);
De-queues the next runnable, whether it is ready to run or not.
void writeRunnable(const RWRunnable& r);
Writes a runnable with no guard into the queue. The absence of a guard means that the guard for that runnable always evaluates to TRUE.
void writeRunnable(const RWRunnable& r, const RWRunnableGuard& g);
Writes a runnable and guard into the queue. The guard is a functor that is called to determine whether a runnable is ready to execute.
RWRunnableServer, RWServerPool
©Copyright 2000, Rogue Wave Software, Inc.
Contact Rogue Wave about documentation or support issues.