Package | Description |
---|---|
groovyx.gpars.dataflow |
This package holds classes for basic dataflow concurrency constructs, like dataflow variables, streams and threads.
|
groovyx.gpars.dataflow.remote | |
groovyx.gpars.remote.message |
This package holds message classes for the remote actors implementation.
|
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.
|
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.
|
Modifier and Type | Class and Description |
---|---|
class |
RemoteDataflowQueue<T>
Proxy object for remote instance of Queue.
|
class |
RemoteDataflowVariable<T>
Proxy object for remote Variable instance.
|
Modifier and Type | Field and Description |
---|---|
private DataflowChannel<T> |
RemoteDataflowQueueEnqueueValueMsg.queue |
(package private) DataflowChannel<?> |
RemoteDataflowQueueReplyMsg.queue |
private DataflowChannel<?> |
RemoteDataflowQueueValueRequestMsg.queue |