class DataflowSelectorActor extends DataflowProcessorActor
Iteratively waits for values on the inputs. Once all a value is available (received as a message), the selector's body is run.
Actor.MyRemoteHandle, Actor.RemoteActor
MessageStream.RemoteMessageStream, MessageStream.SendTo
Modifier and Type | Field and Description |
---|---|
protected boolean |
passIndex |
CANNOT_OBTAIN_THE_SEMAPHORE_TO_FORK_OPERATOR_S_BODY, code, inputs, outputs, owningProcessor, stoppingGently
ACTOR_HAS_ALREADY_BEEN_STARTED, CANNOT_SEND_REPLIES_NO_SENDER_HAS_BEEN_REGISTERED, currentThread, parallelGroup, START_MESSAGE, STOP_MESSAGE, TERMINATE_MESSAGE, TIMEOUT, TIMEOUT_MESSAGE, timer
serialHandle
Constructor and Description |
---|
DataflowSelectorActor(DataflowSelector owningOperator,
PGroup group,
java.util.List outputs,
java.util.List inputs,
groovy.lang.Closure code) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
afterStart() |
private void |
handlePoisonPillInSelector(int index,
java.lang.Object value) |
void |
onMessage(java.lang.Object message)
All messages unhandled by sub-classes will result in an exception being thrown
|
(package private) void |
startTask(int index,
java.lang.Object result) |
afterStop, checkPoison, fireMessageArrived, forwardPoisonPill, isControlMessage, onException, registerChannelListenersToAllInputs, reportException, send
getSender, hasBeenStopped, initialize, isActive, isFair, makeFair, reply, replyIfExists, setParallelGroup, setTimeout, silentStart, start, stop, sweepNextMessage, terminate
createActorMessage, createRemoteHandle, deregisterCurrentActorWithThread, getJoinLatch, getParallelGroup, handleException, handleInterrupt, handleStart, handleTermination, handleTimeout, isActorThread, join, join, join, join, onStop, registerCurrentActorWithThread, sendAndContinue, sendAndPromise, threadBoundActor
call, getRemoteClass, leftShift, send, send, sendAndWait, sendAndWait, sendAndWait
getOrCreateSerialHandle, writeReplace
DataflowSelectorActor(DataflowSelector owningOperator, PGroup group, java.util.List outputs, java.util.List inputs, groovy.lang.Closure code)
final void afterStart()
afterStart
in class DataflowProcessorActor
public final void onMessage(java.lang.Object message)
DataflowProcessorActor
onMessage
in class DataflowProcessorActor
message
- The unhandled messageprivate void handlePoisonPillInSelector(int index, java.lang.Object value)
void startTask(int index, java.lang.Object result)