|
org.codehaus.gpars | |||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||
| Interface Summary | |
|---|---|
| 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. |
| 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 | 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}. |
| 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–2012 Václav Pech. All Rights Reserved.