Uses of Class
groovyx.gpars.dataflow.DataFlowExpression

Packages that use DataFlowExpression

groovyx.gpars.actor	This package holds classes forming the public actor API.
groovyx.gpars.dataflow	This package holds classes for basic dataflow concurrency constructs, like dataflow variables, streams and threads.
groovyx.gpars.dataflow.stream

Uses of DataFlowExpression in groovyx.gpars.actor

Fields in groovyx.gpars.actor declared as DataFlowExpression

private DataFlowExpression<java.lang.Object>	Actor.joinLatch
private DataFlowExpression<java.lang.Object>	Actor.MyRemoteHandle.joinLatch

Methods in groovyx.gpars.actor that return DataFlowExpression

DataFlowExpression<java.lang.Object>

Actor.getJoinLatch() Join-point for this actor

Constructors in groovyx.gpars.actor with parameters of type DataFlowExpression

Actor.MyRemoteHandle(SerialHandle handle, SerialContext host, DataFlowExpression<java.lang.Object> joinLatch)

Actor.RemoteActor(SerialContext host, DataFlowExpression<java.lang.Object> jointLatch)

Actor(DataFlowExpression<java.lang.Object> joinLatch)
Constructor to be used by deserialization

Actor(DataFlowExpression<java.lang.Object> joinLatch, groovyx.gpars.group.PGroup parallelGroup)

Uses of DataFlowExpression in groovyx.gpars.dataflow

Subclasses of DataFlowExpression in groovyx.gpars.dataflow

class	DataFlowComplexExpression<T>
private static class	DataFlowExpression.TransformMany<V>
private static class	DataFlowExpression.TransformOne<V>
class	DataFlowGetPropertyExpression<T> DFE which evaluate property when receiver became available
class	DataFlowInvocationExpression Data flow expression which invokes method of object after receiver and all arguments became available
class	DataFlowVariable<T> Represents a thread-safe single-assignment, multi-read variable.
static class	DataFlowVariable.RemoteDataFlowVariable<T>
class	RemoteDataFlowExpression<T>

Fields in groovyx.gpars.dataflow declared as DataFlowExpression

private DataFlowExpression<T>	DataFlowExpression.BindDataFlow.expr
private DataFlowExpression<T>	DataFlowGetPropertyExpression.receiver

Fields in groovyx.gpars.dataflow with type parameters of type DataFlowExpression

protected static java.util.concurrent.atomic.AtomicIntegerFieldUpdater<DataFlowExpression>	DataFlowExpression.stateUpdater Updater for the state field
protected static java.util.concurrent.atomic.AtomicReferenceFieldUpdater<DataFlowExpression,DataFlowExpression.WaitingThread>	DataFlowExpression.waitingUpdater Updater for the waiting field

Methods in groovyx.gpars.dataflow that return DataFlowExpression

private DataFlowExpression<T>	DataFlowQueue.hookWheneverBoundListeners(DataFlowExpression<T> expr) Hooks the registered when bound handlers to the supplied dataflow expression
DataFlowExpression<T>	DataFlowExpression.poll() Retrieves the bound value.
DataFlowExpression<T>	DataFlowQueue.poll() Retrieves the value at the head of the buffer.
DataFlowExpression<T>	DataFlowReadChannel.poll() Retrieves the value at the head of the buffer.
static <V> DataFlowExpression<V>	DataFlowExpression.transform(java.lang.Object another, groovy.lang.Closure closure)

Methods in groovyx.gpars.dataflow with parameters of type DataFlowExpression

private DataFlowExpression<T>

DataFlowQueue.hookWheneverBoundListeners(DataFlowExpression<T> expr) Hooks the registered when bound handlers to the supplied dataflow expression

Constructors in groovyx.gpars.dataflow with parameters of type DataFlowExpression

DataFlowExpression.BindDataFlow(DataFlowExpression<T> expr, T message, java.util.UUID hostId)

DataFlowGetPropertyExpression(DataFlowExpression<T> expression, java.lang.String name)

Uses of DataFlowExpression in groovyx.gpars.dataflow.stream

Methods in groovyx.gpars.dataflow.stream that return DataFlowExpression

private DataFlowExpression<T>	DataFlowStream.hookWheneverBoundListeners(DataFlowExpression<T> expr) Hooks the registered when bound handlers to the supplied dataflow expression
DataFlowExpression<T>	DataFlowStreamReadAdapter.poll()

Methods in groovyx.gpars.dataflow.stream with parameters of type DataFlowExpression

private DataFlowExpression<T>

DataFlowStream.hookWheneverBoundListeners(DataFlowExpression<T> expr) Hooks the registered when bound handlers to the supplied dataflow expression