groovyx.gpars.dataflow.operator
[Java] Class DataflowOperatorActor
java.lang.Object
groovyx.gpars.serial.WithSerialId
groovyx.gpars.actor.impl.MessageStream
groovyx.gpars.actor.Actor
groovyx.gpars.actor.AbstractLoopingActor
groovyx.gpars.actor.StaticDispatchActor
groovyx.gpars.dataflow.operator.DataflowProcessorActor
groovyx.gpars.dataflow.operator.DataflowOperatorActor
@SuppressWarnings({"RawUseOfParameterizedType", "unchecked"})
class DataflowOperatorActor
extends DataflowProcessorActor
An operator's internal actor. Repeatedly polls inputs and once they're all available it performs the operator's body.
Iteratively waits for enough values from inputs.
Once all required inputs are available (received as messages), the operator's body is run.
- Authors:
- Vaclav Pech
Field Summary |
private java.util.Map |
values
|
Fields inherited from class Actor
|
ACTOR_HAS_ALREADY_BEEN_STARTED, AFTER_START, CANNOT_SEND_REPLIES_NO_SENDER_HAS_BEEN_REGISTERED, EMPTY_ARGUMENTS, ON_DELIVERY_ERROR, RESPONDS_TO, START_MESSAGE, STOP_MESSAGE, TERMINATE_MESSAGE, TIMEOUT, TIMEOUT_MESSAGE, currentActorPerThread, currentThread, joinLatch, onStop, parallelGroup, serialVersionUID, timer |
Methods inherited from class DataflowProcessorActor
|
afterStart, afterStop, checkPoison, fireMessageArrived, forwardPoisonPill, isControlMessage, onException, onMessage, registerChannelListenersToAllInputs, reportException, send |
Methods inherited from class AbstractLoopingActor
|
cancelCurrentTimeoutTask, doStart, getCore, getSender, hasBeenStopped, initialize, isActive, isFair, makeFair, reply, replyIfExists, runEnhancedWithoutRepliesOnMessages, send, setParallelGroup, setTimeout, silentStart, start, stop, sweepNextMessage, terminate |
Methods inherited from class Actor
|
callDynamic, createActorMessage, createRemoteHandle, deregisterCurrentActorWithThread, getJoinLatch, getParallelGroup, handleException, handleInterrupt, handleStart, handleTermination, handleTimeout, hasBeenStopped, isActive, isActorThread, join, join, join, join, onStop, registerCurrentActorWithThread, sendAndContinue, sendAndPromise, setParallelGroup, silentStart, start, stop, sweepNextMessage, sweepQueue, terminate, threadBoundActor |
values
private java.util.Map values
-
DataflowOperatorActor
DataflowOperatorActor(DataflowOperator owningOperator, PGroup group, java.util.List outputs, java.util.List inputs, groovy.lang.Closure code)
-
afterStart
@Override
@SuppressWarnings({"UnusedDeclaration"})
final void afterStart()
-
onMessage
@Override
public final void onMessage(java.lang.Object message)
-
queryInputs
private void queryInputs(boolean initialRun)
-
startTask
@SuppressWarnings({"CatchGenericClass"})
void startTask(java.util.List results)
-
Copyright © 2008–2012 Václav Pech. All Rights Reserved.