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 |
SyncDataflowQueue<T>
Represents a thread-safe synchronous data flow stream.
|
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.ConcurrentMap<java.lang.String,DataflowQueue<?>> |
RemoteDataflows.publishedQueues
Stores DataflowQueues published in context of this instance of RemoteDataflows.
|
Modifier and Type | Method and Description |
---|---|
void |
RemoteDataflows.publish(DataflowQueue<?> queue,
java.lang.String name)
Publishes
DataflowQueue under given name. |
Constructor and Description |
---|
RemoteDataflowQueueReplyMsg(java.lang.String name,
DataflowQueue<?> queue) |