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
DataflowChannelListener<T>	Gets notified about state changes inside DataflowReadChannels
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.
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>
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.
SyncDataflowBroadcast<T>	Offers a synchronous deterministic one-to-many and many-to-many messaging alternative to SyncDataflowQueue.
SyncDataflowQueue<T>	Represents a thread-safe synchronous data flow stream.
SyncDataflowStreamReadAdapter<T>	Provides a special implementation of DataflowStreamReadAdapter, which cooperates with SyncDataflowBroadcast subscription and un-subscription mechanism.
SyncDataflowVariable<T>	A synchronous variant of DataflowVariable, which blocks the writer as well as the readers.

Package groovyx.gpars.dataflow Description

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