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.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 |
SyncDataflowVariable<T>
A synchronous variant of DataflowVariable, which blocks the writer as well as the readers.
|
Modifier and Type | Method and Description |
---|---|
<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) |
<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> |
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> |
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.
|
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.
|
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.
|
Modifier and Type | Method and Description |
---|---|
<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.
|
Modifier and Type | Method and Description |
---|---|
Promise<java.lang.Boolean> |
CountingPoisonPill.getTermination() |
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.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.
|
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.
|
private static <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)
Waits for the promise identified by the index to be bound and then passes on to the next promise in the list
|