Uses of Interface
groovyx.gpars.dataflow.Promise

Packages that use Promise

groovyx.gpars.actor	This package holds classes forming the public actor API.
groovyx.gpars.dataflow	This package holds classes for basic dataflow concurrency constructs, like dataflow variables, streams and threads.
groovyx.gpars.dataflow.expression
groovyx.gpars.dataflow.operator	This package holds classes representing operators and channels necessary for full dataflow concurrency.
groovyx.gpars.dataflow.operator.component
groovyx.gpars.dataflow.stream
groovyx.gpars.group

Uses of Promise in groovyx.gpars.actor

Methods in groovyx.gpars.actor that return Promise

<T> Promise<java.lang.Object>

Actor.sendAndPromise(T message) Sends a message and returns a promise for the reply.

Uses of Promise in groovyx.gpars.dataflow

Classes in groovyx.gpars.dataflow that implement Promise

class	DataflowVariable<T> Represents a thread-safe single-assignment, multi-read variable.
static class	DataflowVariable.RemoteDataflowVariable<T>
class	SyncDataflowVariable<T> A synchronous variant of DataflowVariable, which blocks the writer as well as the readers.

Methods in groovyx.gpars.dataflow that return Promise

<V> Promise<V>	DataflowQueue.rightShift(groovy.lang.Closure<V> closure) Schedule closure to be executed by pooled actor after data became available.
<V> Promise<V>	DataflowReadChannel.rightShift(groovy.lang.Closure<V> closure) Schedule closure to be executed after data became available.
<V> Promise<V>	Promise.rightShift(groovy.lang.Closure<V> closure) Schedule closure to be executed after data became available.
<V> Promise<V>	SyncDataflowStreamReadAdapter.rightShift(groovy.lang.Closure<V> closure)
static <T> Promise<T>	Dataflow.task(java.util.concurrent.Callable<T> callable) Creates a new task assigned to a thread from the current parallel group.
static <T> Promise<T>	Dataflow.task(groovy.lang.Closure<T> code) Creates a new task assigned to a thread from the default dataflow parallel group.
static Promise<java.lang.Object>	Dataflow.task(java.lang.Runnable runnable) Creates a new task assigned to a thread from the current parallel group.
<V> Promise<V>	DataflowQueue.then(groovy.lang.Closure<V> closure) Schedule closure to be executed after data became available.
<V> Promise<V>	DataflowReadChannel.then(groovy.lang.Closure<V> closure) Schedule closure to be executed after data became available.
<V> Promise<V>	Promise.then(groovy.lang.Closure<V> closure) Schedule closure to be executed after data became available.
<V> Promise<V>	DataflowVariable.then(groovy.lang.Closure<V> closure, groovy.lang.Closure<V> errorHandler) Schedule closure to be executed after data became available.
<V> Promise<V>	Promise.then(groovy.lang.Closure<V> closure, groovy.lang.Closure<V> errorHandler) Schedule closure to be executed after data became available.
<V> Promise<V>	DataflowQueue.then(PGroup group, groovy.lang.Closure<V> closure) Schedule closure to be executed after data becomes available.
<V> Promise<V>	DataflowReadChannel.then(PGroup group, groovy.lang.Closure<V> closure) Schedule closure to be executed after data becomes available.
<V> Promise<V>	Promise.then(PGroup group, groovy.lang.Closure<V> closure) Schedule closure to be executed after data becomes available.
<V> Promise<V>	DataflowVariable.then(PGroup group, groovy.lang.Closure<V> closure, groovy.lang.Closure<V> errorHandler) Schedule closure to be executed after data becomes available.
<V> Promise<V>	Promise.then(PGroup group, groovy.lang.Closure<V> closure, groovy.lang.Closure<V> errorHandler) Schedule closure to be executed after data becomes available.
<V> Promise<V>	DataflowQueue.then(Pool pool, groovy.lang.Closure<V> closure) Schedule closure to be executed after data becomes available.
<V> Promise<V>	DataflowReadChannel.then(Pool pool, groovy.lang.Closure<V> closure) Schedule closure to be executed after data becomes available.
<V> Promise<V>	Promise.then(Pool pool, groovy.lang.Closure<V> closure) Schedule closure to be executed after data becomes available.
<V> Promise<V>	DataflowVariable.then(Pool pool, groovy.lang.Closure<V> closure, groovy.lang.Closure<V> errorHandler) Schedule closure to be executed after data becomes available.
<V> Promise<V>	Promise.then(Pool pool, groovy.lang.Closure<V> closure, groovy.lang.Closure<V> errorHandler) Schedule closure to be executed after data becomes available.
static <T> Promise<T>	Dataflow.whenAllBound(java.util.List<Promise> promises, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
static <T> Promise<T>	Dataflow.whenAllBound(java.util.List<Promise> promises, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
static <T> Promise<T>	Dataflow.whenAllBound(Promise promise1, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
static <T> Promise<T>	Dataflow.whenAllBound(Promise promise1, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
static <T> Promise<T>	Dataflow.whenAllBound(Promise promise1, Promise promise2, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
static <T> Promise<T>	Dataflow.whenAllBound(Promise promise1, Promise promise2, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
static <T> Promise<T>	Dataflow.whenAllBound(Promise promise1, Promise promise2, Promise promise3, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
static <T> Promise<T>	Dataflow.whenAllBound(Promise promise1, Promise promise2, Promise promise3, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
static <T> Promise<T>	Dataflow.whenAllBound(Promise promise1, Promise promise2, Promise promise3, Promise promise4, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
static <T> Promise<T>	Dataflow.whenAllBound(Promise promise1, Promise promise2, Promise promise3, Promise promise4, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.

Methods in groovyx.gpars.dataflow with parameters of type Promise

static <T> Promise<T>	Dataflow.whenAllBound(Promise promise1, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
static <T> Promise<T>	Dataflow.whenAllBound(Promise promise1, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
static <T> Promise<T>	Dataflow.whenAllBound(Promise promise1, Promise promise2, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
static <T> Promise<T>	Dataflow.whenAllBound(Promise promise1, Promise promise2, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
static <T> Promise<T>	Dataflow.whenAllBound(Promise promise1, Promise promise2, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
static <T> Promise<T>	Dataflow.whenAllBound(Promise promise1, Promise promise2, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
static <T> Promise<T>	Dataflow.whenAllBound(Promise promise1, Promise promise2, Promise promise3, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
static <T> Promise<T>	Dataflow.whenAllBound(Promise promise1, Promise promise2, Promise promise3, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
static <T> Promise<T>	Dataflow.whenAllBound(Promise promise1, Promise promise2, Promise promise3, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
static <T> Promise<T>	Dataflow.whenAllBound(Promise promise1, Promise promise2, Promise promise3, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
static <T> Promise<T>	Dataflow.whenAllBound(Promise promise1, Promise promise2, Promise promise3, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
static <T> Promise<T>	Dataflow.whenAllBound(Promise promise1, Promise promise2, Promise promise3, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
static <T> Promise<T>	Dataflow.whenAllBound(Promise promise1, Promise promise2, Promise promise3, Promise promise4, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
static <T> Promise<T>	Dataflow.whenAllBound(Promise promise1, Promise promise2, Promise promise3, Promise promise4, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
static <T> Promise<T>	Dataflow.whenAllBound(Promise promise1, Promise promise2, Promise promise3, Promise promise4, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
static <T> Promise<T>	Dataflow.whenAllBound(Promise promise1, Promise promise2, Promise promise3, Promise promise4, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
static <T> Promise<T>	Dataflow.whenAllBound(Promise promise1, Promise promise2, Promise promise3, Promise promise4, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
static <T> Promise<T>	Dataflow.whenAllBound(Promise promise1, Promise promise2, Promise promise3, Promise promise4, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
static <T> Promise<T>	Dataflow.whenAllBound(Promise promise1, Promise promise2, Promise promise3, Promise promise4, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
static <T> Promise<T>	Dataflow.whenAllBound(Promise promise1, Promise promise2, Promise promise3, Promise promise4, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.

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

static <T> Promise<T>	Dataflow.whenAllBound(java.util.List<Promise> promises, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
static <T> Promise<T>	Dataflow.whenAllBound(java.util.List<Promise> promises, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.

Uses of Promise in groovyx.gpars.dataflow.expression

Methods in groovyx.gpars.dataflow.expression that return Promise

<V> Promise<V>	DataflowExpression.rightShift(groovy.lang.Closure<V> closure) Schedule closure to be executed by pooled actor after data became available.
<V> Promise<V>	DataflowExpression.then(groovy.lang.Closure<V> closure) Schedule closure to be executed after data became available.
<V> Promise<V>	DataflowExpression.then(PGroup group, groovy.lang.Closure<V> closure) Schedule closure to be executed after data becomes available.
<V> Promise<V>	DataflowExpression.then(Pool pool, groovy.lang.Closure<V> closure) Schedule closure to be executed after data becomes available.

Uses of Promise in groovyx.gpars.dataflow.operator

Methods in groovyx.gpars.dataflow.operator that return Promise

Promise<java.lang.Boolean>	CountingPoisonPill.getTermination() Retrieves the promise for termination
Promise<java.lang.Boolean>	ImmediateCountingPoisonPill.getTermination() Retrieves the promise for termination
Promise<java.lang.Boolean>	PoisonTrackCounter.getTermination()

Uses of Promise in groovyx.gpars.dataflow.operator.component

Methods in groovyx.gpars.dataflow.operator.component that return Promise

Promise<java.lang.Boolean>

GracefulShutdownMonitor.shutdownNetwork() Initializes the shutdown process.

Uses of Promise in groovyx.gpars.dataflow.stream

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

<V> Promise<V>	DataflowStreamReadAdapter.rightShift(groovy.lang.Closure<V> closure)
<V> Promise<V>	DataflowStreamReadAdapter.then(groovy.lang.Closure<V> closure) Schedule closure to be executed after data became available.
<V> Promise<V>	DataflowStreamReadAdapter.then(PGroup group, groovy.lang.Closure<V> closure) Schedule closure to be executed after data becomes available.
<V> Promise<V>	DataflowStreamReadAdapter.then(Pool pool, groovy.lang.Closure<V> closure) Schedule closure to be executed after data becomes available.

Uses of Promise in groovyx.gpars.group

Methods in groovyx.gpars.group that return Promise

<T> Promise<T>	PGroup.task(java.util.concurrent.Callable<T> callable) Creates a new task assigned to a thread from the current parallel group.
<T> Promise<T>	PGroup.task(groovy.lang.Closure<T> code) Creates a new task assigned to a thread from the current parallel group.
Promise<java.lang.Object>	PGroup.task(java.lang.Runnable code) Creates a new task assigned to a thread from the current parallel group.
<T> Promise<T>	PGroup.whenAllBound(java.util.List<Promise> promises, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
<T> Promise<T>	PGroup.whenAllBound(java.util.List<Promise> promises, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
<T> Promise<T>	PGroup.whenAllBound(Promise promise1, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
<T> Promise<T>	PGroup.whenAllBound(Promise promise1, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
<T> Promise<T>	PGroup.whenAllBound(Promise promise1, Promise promise2, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
<T> Promise<T>	PGroup.whenAllBound(Promise promise1, Promise promise2, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
<T> Promise<T>	PGroup.whenAllBound(Promise promise1, Promise promise2, Promise promise3, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
<T> Promise<T>	PGroup.whenAllBound(Promise promise1, Promise promise2, Promise promise3, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
<T> Promise<T>	PGroup.whenAllBound(Promise promise1, Promise promise2, Promise promise3, Promise promise4, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
<T> Promise<T>	PGroup.whenAllBound(Promise promise1, Promise promise2, Promise promise3, Promise promise4, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.

Methods in groovyx.gpars.group with parameters of type Promise

<T> Promise<T>	PGroup.whenAllBound(Promise promise1, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
<T> Promise<T>	PGroup.whenAllBound(Promise promise1, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
<T> Promise<T>	PGroup.whenAllBound(Promise promise1, Promise promise2, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
<T> Promise<T>	PGroup.whenAllBound(Promise promise1, Promise promise2, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
<T> Promise<T>	PGroup.whenAllBound(Promise promise1, Promise promise2, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
<T> Promise<T>	PGroup.whenAllBound(Promise promise1, Promise promise2, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
<T> Promise<T>	PGroup.whenAllBound(Promise promise1, Promise promise2, Promise promise3, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
<T> Promise<T>	PGroup.whenAllBound(Promise promise1, Promise promise2, Promise promise3, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
<T> Promise<T>	PGroup.whenAllBound(Promise promise1, Promise promise2, Promise promise3, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
<T> Promise<T>	PGroup.whenAllBound(Promise promise1, Promise promise2, Promise promise3, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
<T> Promise<T>	PGroup.whenAllBound(Promise promise1, Promise promise2, Promise promise3, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
<T> Promise<T>	PGroup.whenAllBound(Promise promise1, Promise promise2, Promise promise3, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
<T> Promise<T>	PGroup.whenAllBound(Promise promise1, Promise promise2, Promise promise3, Promise promise4, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
<T> Promise<T>	PGroup.whenAllBound(Promise promise1, Promise promise2, Promise promise3, Promise promise4, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
<T> Promise<T>	PGroup.whenAllBound(Promise promise1, Promise promise2, Promise promise3, Promise promise4, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
<T> Promise<T>	PGroup.whenAllBound(Promise promise1, Promise promise2, Promise promise3, Promise promise4, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
<T> Promise<T>	PGroup.whenAllBound(Promise promise1, Promise promise2, Promise promise3, Promise promise4, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
<T> Promise<T>	PGroup.whenAllBound(Promise promise1, Promise promise2, Promise promise3, Promise promise4, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
<T> Promise<T>	PGroup.whenAllBound(Promise promise1, Promise promise2, Promise promise3, Promise promise4, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
<T> Promise<T>	PGroup.whenAllBound(Promise promise1, Promise promise2, Promise promise3, Promise promise4, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.

Method parameters in groovyx.gpars.group with type arguments of type Promise

<T> Promise<T>	PGroup.whenAllBound(java.util.List<Promise> promises, groovy.lang.Closure<T> code) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
<T> Promise<T>	PGroup.whenAllBound(java.util.List<Promise> promises, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
private <T> void	PGroup.whenAllBound(java.util.List<Promise> promises, int index, java.util.List<java.lang.Object> values, DataflowVariable<T> result, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler) Waits for the promise identified by the index to be bound and then passes on to the next promise in the list