Package groovyx.gpars.dataflow

This package holds classes for basic dataflow concurrency constructs, like dataflow variables, streams and threads.

See:
Description

Interface Summary

DataflowChannel<T>	A common interface for all dataflow variables, streams or queues
DataflowReadChannel<T>	A common interface for all dataflow variables, streams or queues
DataflowWriteChannel<T>	A common interface for all writable dataflow variables, streams or queues
Promise<T>	A unifying future-like interface to dataflow variables, asynchronous functions and active objects.

Class Summary

DataCallback	A helper class enabling the 'whenBound()' or 'getValAsync' functionality of a DataflowVariable and DataflowQueue, as well as 'sendAndContinue()' on actors.
DataCallbackWithPool	A helper class enabling the 'whenBound()' or 'getValAsync' functionality of a DataflowVariable and DataflowQueue, whenever a thread pool instead of a PGroup is specified..
Dataflow	Contains factory methods to create dataflow actors and starting them.
DataflowBroadcast<T>	Offers a deterministic one-to-many and many-to-many messaging alternative to DataflowQueue.
DataflowComplexExpression<T>
DataflowExpression<T>	The base class for all dataflow elements.
DataflowExpression.BindDataflow<T>	Represents a remote message binding a value to a remoted DataflowExpression
DataflowExpression.TransformMany<V>
DataflowExpression.TransformOne<V>
DataflowExpression.WaitingThread	A logical representation of a synchronous or asynchronous request to read the value once it is bound.
DataflowGetPropertyExpression<T>	DFE which evaluate property when receiver became available
DataflowInvocationExpression	Data flow expression which invokes method of object after receiver and all arguments became available
DataflowQueue<T>	Represents a thread-safe data flow stream.
Dataflows	Convenience class that makes working with DataflowVariables more comfortable.
DataflowVariable<T>	Represents a thread-safe single-assignment, multi-read variable.
DataflowVariable.RemoteDataflowVariable<T>
RemoteDataflowExpression<T>
Select<T>	A Select allows the user to select a value from multiple channels, which have a value available for read at the moment.
SelectResult<T>	A bean representing the result of the select operation on a Select.

Package groovyx.gpars.dataflow Description

This package holds classes for basic dataflow concurrency constructs, like dataflow variables, streams and threads.