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

Class Summary

DataCallback	A helper class enabling the 'whenBound()' or 'getValAsync' functionality of a DataFlowVariable and DataFlowQueue, as well as 'sendAndContinue()' on actors.
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.
SingleRunActor	An actor representing a dataflow thread.

Package groovyx.gpars.dataflow Description

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