Package | Description |
---|---|
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 |
Modifier and Type | Method and Description |
---|---|
<T> Promise<java.lang.Object> |
Actor.sendAndPromise(T message)
Sends a message and returns a promise for the reply.
|
Modifier and Type | Class and Description |
---|---|
class |
DataflowVariable<T>
Represents a thread-safe single-assignment, multi-read variable.
|
static class |
DataflowVariable.RemoteDataflowVariable<T> |
class |
LazyDataflowVariable<T>
Represents a thread-safe single-assignment, multi-read variable with delayed initialization.
|
class |
SyncDataflowVariable<T>
A synchronous variant of DataflowVariable, which blocks the writer as well as the readers.
|
Modifier and Type | Method and Description |
---|---|
static <T> Promise<T> |
Dataflow.lazyTask(java.util.concurrent.Callable<T> callable)
Creates a new task assigned to a thread from the current parallel group.
|
static <T> Promise<T> |
Dataflow.lazyTask(groovy.lang.Closure<T> code)
Creates a new task assigned to a thread from the default dataflow parallel group.
|
Promise<SelectResult<T>> |
Select.prioritySelectToPromise()
Selects asynchronously a value from a single input channel, which has a value available for read.
|
Promise<SelectResult<T>> |
Select.prioritySelectToPromise(java.util.List<java.lang.Boolean> mask)
Selects asynchronously a value from a single input channel, which has a value available for read.
|
<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) |
Promise<SelectResult<T>> |
Select.selectToPromise()
Selects asynchronously a value from a single randomly chosen input channel, which has a value available for read.
|
private Promise<SelectResult<T>> |
Select.selectToPromise(int startIndex,
java.util.List<java.lang.Boolean> mask)
Invokes the internal select base with a SelectRequest instance ensuring a message is sent, once a value has been selected
|
Promise<SelectResult<T>> |
Select.selectToPromise(java.util.List<java.lang.Boolean> mask)
/**
Selects asynchronously a value from a single randomly chosen input channel, which has a value available for read.
|
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> |
LazyDataflowVariable.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> |
LazyDataflowVariable.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> |
LazyDataflowVariable.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.
|
Promise<java.util.List> |
Promise.thenForkAndJoin(groovy.lang.Closure<? extends java.lang.Object>... closures)
Schedule a set of closures to be executed after data became available on the current promise.
|
Promise<java.util.List> |
Promise.thenForkAndJoin(PGroup group,
groovy.lang.Closure<? extends java.lang.Object>... closures)
Schedule a set of closures to be executed after data became available on the current promise.
|
Promise<java.util.List> |
Promise.thenForkAndJoin(Pool pool,
groovy.lang.Closure<? extends java.lang.Object>... closures)
Schedule a set of closures to be executed after data became available on the current 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.
|
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.
|
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
private Promise<java.util.List> |
DataflowExpression.doThenForkAndJoin(PGroup group,
Pool pool,
groovy.lang.Closure<? extends java.lang.Object>[] closures) |
<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.
|
Promise<java.util.List> |
DataflowExpression.thenForkAndJoin(groovy.lang.Closure<? extends java.lang.Object>... closures)
Schedule a set of closures to be executed after data became available on the current promise.
|
Promise<java.util.List> |
DataflowExpression.thenForkAndJoin(PGroup group,
groovy.lang.Closure<? extends java.lang.Object>... closures)
Schedule a set of closures to be executed after data became available on the current promise.
|
Promise<java.util.List> |
DataflowExpression.thenForkAndJoin(Pool pool,
groovy.lang.Closure<? extends java.lang.Object>... closures)
Schedule a set of closures to be executed after data became available on the current promise.
|
Modifier and Type | Method and Description |
---|---|
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() |
Modifier and Type | Method and Description |
---|---|
Promise<java.lang.Boolean> |
GracefulShutdownMonitor.shutdownNetwork()
Initializes the shutdown process.
|
Modifier and Type | Method and Description |
---|---|
<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.
|
Modifier and Type | Method and Description |
---|---|
<T> Promise<T> |
PGroup.lazyTask(java.util.concurrent.Callable<T> callable)
Creates a new task assigned to a thread from the current parallel group.
|
<T> Promise<T> |
PGroup.lazyTask(groovy.lang.Closure<T> code)
Creates a new task assigned to a thread from the current parallel group.
|
<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.
|
Modifier and Type | Method and Description |
---|---|
<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.
|
Modifier and Type | Method and Description |
---|---|
<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
|