groovyx.gpars.dataflow (org.codehaus.gpars)

Interface Summary
Interface	Description
BindErrorListener	Gets notified about errors when binding values to DataflowVariables
DataflowChannel	A common interface for all dataflow variables, streams or queues
DataflowChannelListener	Gets notified about state changes inside DataflowReadChannels
DataflowReadChannel	A common interface for all dataflow variables, streams or queues
DataflowWriteChannel	A common interface for all writable dataflow variables, streams or queues
Promise	A unifying future-like interface to dataflow variables, asynchronous functions and active objects.
SelectableChannel	Created with IntelliJ IDEA.

Class Summary
Class	Description
BindErrorAdapter	An empty implementation of BindErrorListener
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	Offers a deterministic one-to-many and many-to-many messaging alternative to DataflowQueue.
DataflowQueue	Represents a thread-safe data flow stream.
DataflowVariable	Represents a thread-safe single-assignment, multi-read variable.
Dataflows	Convenience class that makes working with DataflowVariables more comfortable.
KanbanFlow	A KanbanFlow is a network of dataflow connections made up from KanbanLinks.
KanbanLink	A KanbanLink is the simplest possible producer-consumer pair in a kanban-like scenario as described in	KanbanTray	A KanbanTray is a container for passing a product around a {@KanbanLink}.
LazyDataflowVariable	Represents a thread-safe single-assignment, multi-read variable with delayed initialization.
ProcessingNode	A ProcessingNode specifies a DataflowOperator: its input and output channels, maxForks and its body of processing logic.
Select	A Select allows the user to select a value from multiple channels, which have a value available for read at the moment.
SelectResult	A bean representing the result of the select operation on a Select.
SyncDataflowBroadcast	Offers a synchronous deterministic one-to-many and many-to-many messaging alternative to SyncDataflowQueue.
SyncDataflowQueue	Represents a thread-safe synchronous data flow stream.
SyncDataflowStreamReadAdapter	Provides a special implementation of DataflowStreamReadAdapter, which cooperates with SyncDataflowBroadcast subscription and un-subscription mechanism.
SyncDataflowVariable	A synchronous variant of DataflowVariable, which blocks the writer as well as the readers.

Package groovyx.gpars.dataflow