public final class DataflowPrioritySelector extends DataflowSelector
guards, select
actor, INPUTS, MAX_FORKS, OUTPUTS, STATE_OBJECT, stateObject
Constructor and Description |
---|
DataflowPrioritySelector(PGroup group,
java.util.Map<java.lang.String,java.lang.Object> channels,
groovy.lang.Closure code)
Creates a priority selector
After creation the selector needs to be started using the start() method.
|
Modifier and Type | Method and Description |
---|---|
void |
doSelect()
Ask for another select operation on the internal select instance.
|
setGuard, setGuards
addDataflowEventListener, bindAllOutputs, bindAllOutputsAtomically, bindAllOutputValues, bindAllOutputValuesAtomically, bindOutput, bindOutput, checkMaxForks, extractInputs, extractOutputs, fireAfterRun, fireAfterStart, fireAfterStop, fireBeforeRun, fireControlMessageArrived, fireCustomEvent, fireMessageArrived, fireMessageSentOut, fireOnException, getOutput, getOutputs, getOutputs, getStateObject, join, removeDataflowEventListener, reportError, shouldBeMultiThreaded, start, start, terminate, terminateAfterNextRun
public DataflowPrioritySelector(PGroup group, java.util.Map<java.lang.String,java.lang.Object> channels, groovy.lang.Closure code)
group
- A parallel group to use threads from in the internal actorchannels
- A map specifying "inputs" and "outputs" - dataflow channels (instances of the DataflowQueue or DataflowVariable classes) to use for inputs and outputscode
- The selector's body to run each time all inputs have a value to readpublic void doSelect()
doSelect
in class DataflowSelector