org.codehaus.gpars

Package groovyx.gpars.dataflow

 

Interface Summary
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
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.
DataflowVariable.RemoteDataflowVariable
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.
 


Copyright © 2008–2013 Václav Pech. All Rights Reserved.