See: Description
| Interface | Description |
|---|---|
| BindErrorListener<T> |
Gets notified about errors when binding values to DataflowVariables
|
| 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.
|
| SelectableChannel<T> |
Created with IntelliJ IDEA.
|
| Class | Description |
|---|---|
| BindErrorAdapter<T> |
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<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> | |
| LazyDataflowVariable<T> |
Represents a thread-safe single-assignment, multi-read variable with delayed initialization.
|
| 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.
|
This package holds classes for basic dataflow concurrency constructs, like dataflow variables, streams and threads.