DataFlowSelectorActor (org.codehaus.gpars)

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 DataFlowSelectorActor

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.DataFlowSelectorActor

class DataFlowSelectorActor
extends DataFlowProcessorActor

An selector's internal actor. Repeatedly polls inputs and once they're all available it performs the selector's body. Iteratively waits for enough values from inputs. Once all required inputs are available (received as messages), the selector'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
`protected boolean`	`passIndex`

Constructor Summary
`DataFlowSelectorActor(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(SelectResult message)`
`java.lang.Object`	`startTask(java.lang.Object index, java.lang.Object result)`

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 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

passIndex

protected final boolean passIndex

Constructor Detail

DataFlowSelectorActor

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

Method Detail

afterStart

void afterStart()

onMessage

public final void onMessage(SelectResult message)

startTask

public java.lang.Object startTask(java.lang.Object index, java.lang.Object result)