Uses of Class
groovyx.gpars.dataflow.DataflowQueue

Packages that use DataflowQueue

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.

Uses of DataflowQueue in groovyx.gpars.dataflow

Subclasses of DataflowQueue in groovyx.gpars.dataflow

Modifier and Type	Class and Description
class	SyncDataflowQueue<T> Represents a thread-safe synchronous data flow stream.

Uses of DataflowQueue in groovyx.gpars.dataflow.remote

Fields in groovyx.gpars.dataflow.remote with type parameters of type DataflowQueue

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.

Methods in groovyx.gpars.dataflow.remote with parameters of type DataflowQueue

Modifier and Type	Method and Description
void	RemoteDataflows.publish(DataflowQueue<?> queue, java.lang.String name) Publishes DataflowQueue under given name.

Uses of DataflowQueue in groovyx.gpars.remote.message

Constructors in groovyx.gpars.remote.message with parameters of type DataflowQueue

Constructor and Description
RemoteDataflowQueueReplyMsg(java.lang.String name, DataflowQueue<?> queue)