Uses of Class
groovyx.gpars.dataflow.DataflowVariable

Packages that use DataflowVariable

groovyx.gpars.activeobject
groovyx.gpars.dataflow	This package holds classes for basic dataflow concurrency constructs, like dataflow variables, streams and threads.
groovyx.gpars.dataflow.stream
groovyx.gpars.util	Various utility classes enhancing basic Java concurrency constructs.

Uses of DataflowVariable in groovyx.gpars.activeobject

Methods in groovyx.gpars.activeobject that return DataflowVariable

(package private) DataflowVariable<java.lang.Object>

InternalActor.submit(java.lang.Object... args) A DataflowVariable is passed to the actor, which will bind it once the result is known.

Uses of DataflowVariable in groovyx.gpars.dataflow

Subclasses of DataflowVariable in groovyx.gpars.dataflow

static class

DataflowVariable.RemoteDataflowVariable<T>

Fields in groovyx.gpars.dataflow declared as DataflowVariable

private static DataflowVariable<java.lang.Object>

Dataflows.DUMMY

Fields in groovyx.gpars.dataflow with type parameters of type DataflowVariable

private java.util.concurrent.LinkedBlockingQueue<DataflowVariable<T>>	DataflowQueue.queue Stores the received DataflowVariables in the buffer.
private java.util.Queue<DataflowVariable<T>>	DataflowQueue.requests Stores unsatisfied requests for values
private java.util.concurrent.ConcurrentMap<java.lang.Object,DataflowVariable<java.lang.Object>>	Dataflows.variables

Methods in groovyx.gpars.dataflow that return DataflowVariable

private DataflowVariable<T>	DataflowQueue.copyDFV(java.util.Queue<DataflowVariable<T>> from, java.util.Queue<DataflowVariable<T>> to)
private DataflowVariable<java.lang.Object>	Dataflows.ensureToContainVariable(java.lang.Object name) The idea is following: - we try to putIfAbsent dummy DFV in to map - if something real already there we are done - if not we obtain lock and put new DFV with double check Unfortunately we have to sync on this as there is no better option (God forbid to sync on name)
private DataflowVariable<java.lang.Object>	Dataflows.putNewUnderLock(java.lang.Object name) Utility method extracted just to help JIT
DataflowVariable<java.lang.Object>	Dataflows.remove(java.lang.Object name) Removes a DFV from the map and binds it to null, if it has not been bound yet
private DataflowVariable<T>	DataflowQueue.retrieveForBind() Takes the first unsatisfied value request and binds a value on it.
private DataflowVariable<T>	DataflowQueue.retrieveOrCreateVariable() Checks whether there's a DFV waiting in the queue and retrieves it.
static DataflowVariable	Dataflow.task(java.util.concurrent.Callable callable) Creates a new task assigned to a thread from the current parallel group.
static DataflowVariable	Dataflow.task(groovy.lang.Closure code) Creates a new task assigned to a thread from the default dataflow parallel group.
static DataflowVariable	Dataflow.task(java.lang.Runnable runnable) Creates a new task assigned to a thread from the current parallel group.

Methods in groovyx.gpars.dataflow that return types with arguments of type DataflowVariable

java.util.Iterator<java.util.Map.Entry<java.lang.Object,DataflowVariable<java.lang.Object>>>

Dataflows.iterator() Convenience method to play nicely with Groovy object iteration methods.

Method parameters in groovyx.gpars.dataflow with type arguments of type DataflowVariable

private DataflowVariable<T>	DataflowQueue.copyDFV(java.util.Queue<DataflowVariable<T>> from, java.util.Queue<DataflowVariable<T>> to)
private DataflowVariable<T>	DataflowQueue.copyDFV(java.util.Queue<DataflowVariable<T>> from, java.util.Queue<DataflowVariable<T>> to)

Uses of DataflowVariable in groovyx.gpars.dataflow.stream

Fields in groovyx.gpars.dataflow.stream declared as DataflowVariable

private DataflowVariable<T>

DataflowStream.first

Methods in groovyx.gpars.dataflow.stream that return DataflowVariable

(package private) DataflowVariable<T>

DataflowStream.getFirstDFV()

Uses of DataflowVariable in groovyx.gpars.util

Methods in groovyx.gpars.util with parameters of type DataflowVariable

static void

PAUtils.evaluateArguments(Pool pool, java.lang.Object[] args, int current, java.util.List<java.lang.Object> soFarArgs, DataflowVariable<java.lang.Object> result, groovy.lang.Closure original, boolean pooledThreadFlag) Performs a single step in the evaluation of parameters passed into an asynchronous function