Package | Description |
---|---|
groovyx.gpars.dataflow.operator |
This package holds classes representing operators and channels necessary for full dataflow concurrency.
|
Modifier and Type | Class and Description |
---|---|
class |
DataflowPrioritySelector
Dataflow selectors and operators (processors) form the basic units in dataflow networks.
|
Constructor and Description |
---|
DataflowSelectorActor(DataflowSelector owningOperator,
PGroup group,
java.util.List outputs,
java.util.List inputs,
groovy.lang.Closure code) |
ForkingDataflowSelectorActor(DataflowSelector owningOperator,
PGroup group,
java.util.List outputs,
java.util.List inputs,
groovy.lang.Closure code,
int maxForks) |