Package | Description |
---|---|
groovyx.gpars.dataflow |
This package holds classes for basic dataflow concurrency constructs, like dataflow variables, streams and threads.
|
Modifier and Type | Method and Description |
---|---|
SelectResult<T> |
Select.call()
Selects a value from a single randomly chosen input channel, which has a value available for read.
|
SelectResult<T> |
Select.call(java.util.List<java.lang.Boolean> mask)
Selects a value from a single randomly chosen input channel, which has a value available for read.
|
SelectResult<T> |
Select.prioritySelect()
Selects a value from a single input channel, which has a value available for read.
|
SelectResult<T> |
Select.prioritySelect(java.util.List<java.lang.Boolean> mask)
Selects a value from a single input channel, which has a value available for read.
|
SelectResult<T> |
Select.select()
Selects a value from a single randomly chosen input channel, which has a value available for read.
|
private SelectResult<T> |
Select.select(int startIndex,
java.util.List<java.lang.Boolean> mask)
Invokes the internal select base with a SelectRequest instance ensuring the current thread can continue returning the correct value, once a value has been selected
|
SelectResult<T> |
Select.select(java.util.List<java.lang.Boolean> mask)
Selects a value from a single randomly chosen input channel, which has a value available for read.
|
Modifier and Type | Method and Description |
---|---|
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.
|
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.
|