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

groovyx.gpars.dataflow
Class SingleRunActor

java.lang.Object
  groovyx.gpars.serial.WithSerialId
      groovyx.gpars.actor.impl.MessageStream
          groovyx.gpars.actor.Actor
              groovyx.gpars.actor.impl.ReplyingMessageStream
                  groovyx.gpars.actor.impl.SequentialProcessingActor
                      groovyx.gpars.actor.AbstractPooledActor
                          groovyx.gpars.dataflow.SingleRunActor

class SingleRunActor
extends AbstractPooledActor

An actor representing a dataflow thread. Runs the supplied block of code inside the act() actor method once.

Authors:
Vaclav Pech, Dierk Koenig Date: Jun 5, 2009

Field Summary
private groovy.lang.Closure body

private static long serialVersionUID

 
Fields inherited from class SequentialProcessingActor
S_ACTIVE_MASK, S_FINISHED_MASK, S_FINISHING_MASK, S_NOT_STARTED, S_RUNNING, S_STOPPED, S_STOPPING, S_STOP_TERMINATE_MASK, S_TERMINATED, S_TERMINATING, afterLoopCode, loopCode, loopCondition, stopFlag, stopFlagUpdater
 
Fields inherited from class ReplyingMessageStream
obj2Sender
 
Fields inherited from class Actor
ACTOR_HAS_ALREADY_BEEN_STARTED, START_MESSAGE, STOP_MESSAGE, TERMINATE_MESSAGE, TIMEOUT_MESSAGE, currentThread, parallelGroup, timer
 
Constructor Summary
SingleRunActor()

Sets the default Dataflow Concurrency actor group on the actor.
 
Method Summary
protected void act()

void setBody(groovy.lang.Closure body)

 
Methods inherited from class AbstractPooledActor
act, handleStart, receive, receive, receive, receiveImpl, receiveImpl
 
Methods inherited from class SequentialProcessingActor
checkStopTerminate, handleTermination, hasBeenStopped, isActive, loop, loop, loop, loop, loop, pollMessage, react, react, react, react, receive, receive, receive, receiveImpl, receiveImpl, run, runReaction, scheduleLoop, send, setParallelGroup, silentStart, start, stop, sweepNextMessage, takeMessage, takeMessage, terminate
 
Methods inherited from class ReplyingMessageStream
getSender, getSenders, reply, replyIfExists, runEnhancedWithRepliesOnMessages
 
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
 

Field Detail

body

private groovy.lang.Closure body

serialVersionUID

private static final long serialVersionUID

 
Constructor Detail

SingleRunActor

public SingleRunActor()
Sets the default Dataflow Concurrency actor group on the actor.

 
Method Detail

act

@Override
protected void act()

setBody

public void setBody(groovy.lang.Closure body)

 

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