groovyx.gpars.dataflow.operator

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<java.lang.Object>

groovyx.gpars.dataflow.operator.DataflowProcessorActor

groovyx.gpars.dataflow.operator.DataflowOperatorActor

All Implemented Interfaces:

java.io.Serializable

Direct Known Subclasses:

ForkingDataflowOperatorActor

 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.

Author:

Vaclav Pech

Nested Class Summary

Nested classes/interfaces inherited from class groovyx.gpars.actor.Actor

Actor.MyRemoteHandle, Actor.RemoteActor

Nested classes/interfaces inherited from class groovyx.gpars.actor.impl.MessageStream

MessageStream.RemoteMessageStream, MessageStream.SendTo

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.Map	values

Fields inherited from class groovyx.gpars.dataflow.operator.DataflowProcessorActor

CANNOT_OBTAIN_THE_SEMAPHORE_TO_FORK_OPERATOR_S_BODY, code, inputs, outputs, owningProcessor, stoppingGently

Fields inherited from class groovyx.gpars.actor.Actor

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

Fields inherited from class groovyx.gpars.serial.WithSerialId

serialHandle

Constructor Summary

Constructors

Constructor and Description
DataflowOperatorActor(DataflowOperator owningOperator, PGroup group, java.util.List outputs, java.util.List inputs, groovy.lang.Closure code)

Method Summary

Methods

Modifier and Type	Method and Description
(package private) void	afterStart()
void	onMessage(java.lang.Object message) All messages unhandled by sub-classes will result in an exception being thrown
private void	queryInputs(boolean initialRun)
(package private) void	startTask(java.util.List<java.lang.Object> results)

Methods inherited from class groovyx.gpars.dataflow.operator.DataflowProcessorActor

afterStop, checkPoison, fireMessageArrived, forwardPoisonPill, isControlMessage, onException, registerChannelListenersToAllInputs, reportException, send

Methods inherited from class groovyx.gpars.actor.AbstractLoopingActor

getSender, hasBeenStopped, initialize, isActive, isFair, makeFair, reply, replyIfExists, setParallelGroup, setTimeout, silentStart, start, stop, sweepNextMessage, terminate

Methods inherited from class groovyx.gpars.actor.Actor

createActorMessage, createRemoteHandle, deregisterCurrentActorWithThread, getJoinLatch, getParallelGroup, handleException, handleInterrupt, handleStart, handleTermination, handleTimeout, isActorThread, join, join, join, join, onStop, registerCurrentActorWithThread, sendAndContinue, sendAndPromise, threadBoundActor

Methods inherited from class groovyx.gpars.actor.impl.MessageStream

call, getRemoteClass, leftShift, send, send, sendAndWait, sendAndWait, sendAndWait

Methods inherited from class groovyx.gpars.serial.WithSerialId

getOrCreateSerialHandle, writeReplace

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

values

private java.util.Map values

Constructor Detail

DataflowOperatorActor

DataflowOperatorActor(DataflowOperator owningOperator,
                     PGroup group,
                     java.util.List outputs,
                     java.util.List inputs,
                     groovy.lang.Closure code)

Method Detail

afterStart

final void afterStart()

Overrides:

afterStart in class DataflowProcessorActor

queryInputs

private void queryInputs(boolean initialRun)

onMessage

public final void onMessage(java.lang.Object message)

Description copied from class: DataflowProcessorActor

All messages unhandled by sub-classes will result in an exception being thrown

Overrides:

onMessage in class DataflowProcessorActor

Parameters:

message - The unhandled message

startTask

void startTask(java.util.List<java.lang.Object> results)