Overview  Package   Class  Deprecated  Index  Help 
org.codehaus.gpars
FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | PROPERTY | CONSTR | METHOD DETAIL: FIELD | PROPERTY | CONSTR | METHOD

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.DynamicDispatchActor
                      groovyx.gpars.dataflow.operator.DataFlowProcessorActor
                          groovyx.gpars.dataflow.operator.DataFlowOperatorActor

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.

Field Summary
 
Fields inherited from class Actor
ACTOR_HAS_ALREADY_BEEN_STARTED, START_MESSAGE, STOP_MESSAGE, TERMINATE_MESSAGE, TIMEOUT_MESSAGE, currentThread, parallelGroup, timer
 
Property Summary
java.util.Map values

 
Constructor Summary
DataFlowOperatorActor(java.lang.Object owningOperator, java.lang.Object group, java.lang.Object outputs, java.lang.Object inputs, java.lang.Object code)

 
Method Summary
void afterStart()

void onMessage(java.lang.Object message)

private java.lang.Object queryInputs(boolean initialRun)

java.lang.Object startTask(java.lang.Object results)

 
Methods inherited from class DataFlowProcessorActor
reportException, send
 
Methods inherited from class DynamicDispatchActor
when
 
Methods inherited from class AbstractLoopingActor
getCore, getSender, hasBeenStopped, initialize, isActive, isFair, makeFair, reply, replyIfExists, send, setParallelGroup, setTimeout, silentStart, start, stop, sweepNextMessage, terminate
 
Methods inherited from class Actor
createActorMessage, createRemoteHandle, deregisterCurrentActorWithThread, getJoinLatch, getParallelGroup, handleException, handleInterrupt, handleStart, handleTermination, handleTimeout, hasBeenStopped, isActive, isActorThread, join, join, join, join, onStop, registerCurrentActorWithThread, sendAndContinue, setParallelGroup, silentStart, start, stop, sweepNextMessage, sweepQueue, terminate, threadBoundActor
 
Methods inherited from class MessageStream
call, getRemoteClass, leftShift, reInterrupt, send, send, send, sendAndWait, sendAndWait, sendAndWait
 
Methods inherited from class WithSerialId
createRemoteHandle, getOrCreateSerialHandle, getRemoteClass, writeReplace
 

Property Detail

values

java.util.Map values

 
Constructor Detail

DataFlowOperatorActor

public DataFlowOperatorActor(java.lang.Object owningOperator, java.lang.Object group, java.lang.Object outputs, java.lang.Object inputs, java.lang.Object code)

 
Method Detail

afterStart

public final void afterStart()

onMessage

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

queryInputs

private final java.lang.Object queryInputs(boolean initialRun)

startTask

public java.lang.Object startTask(java.lang.Object results)

 

Copyright © 2008–2010 Václav Pech. All Rights Reserved.