Package | Description |
---|---|
groovyx.gpars.dataflow |
This package holds classes for basic dataflow concurrency constructs, like dataflow variables, streams and threads.
|
Modifier and Type | Class and Description |
---|---|
class |
DataflowQueue<T>
Represents a thread-safe data flow stream.
|
class |
DataflowVariable<T>
Represents a thread-safe single-assignment, multi-read variable.
|
static class |
DataflowVariable.RemoteDataflowVariable<T> |
class |
LazyDataflowVariable<T>
Represents a thread-safe single-assignment, multi-read variable with delayed initialization.
|
class |
SyncDataflowQueue<T>
Represents a thread-safe synchronous data flow stream.
|
class |
SyncDataflowVariable<T>
A synchronous variant of DataflowVariable, which blocks the writer as well as the readers.
|