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

All Implemented Interfaces:

java.io.Serializable, java.lang.Runnable

public final class SingleRunActor
extends AbstractPooledActor

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

Author:

Vaclav Pech, Dierk Koenig Date: Jun 5, 2009

See Also:

Serialized Form

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

private groovy.lang.Closure	body
private static long	serialVersionUID

Fields inherited from class groovyx.gpars.actor.impl.SequentialProcessingActor

afterLoopCode, loopCode, loopCondition, S_ACTIVE_MASK, S_FINISHED_MASK, S_FINISHING_MASK, S_NOT_STARTED, S_RUNNING, S_STOP_TERMINATE_MASK, S_STOPPED, S_STOPPING, S_TERMINATED, S_TERMINATING, stopFlag, stopFlagUpdater

Fields inherited from class groovyx.gpars.actor.impl.ReplyingMessageStream

obj2Sender

Fields inherited from class groovyx.gpars.actor.Actor

ACTOR_HAS_ALREADY_BEEN_STARTED, currentThread, parallelGroup, START_MESSAGE, STOP_MESSAGE, TERMINATE_MESSAGE, TIMEOUT, TIMEOUT_MESSAGE, timer

Fields inherited from class groovyx.gpars.serial.WithSerialId

serialHandle

Constructor Summary

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

Method Summary

protected void	act() This method represents the body of the actor.
void	setBody(groovy.lang.Closure body)

Methods inherited from class groovyx.gpars.actor.AbstractPooledActor

handleStart, receive, receive, receive, receiveImpl, receiveImpl

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

handleTermination, hasBeenStopped, checkStopTerminate, isActive, loop, loop, loop, loop, loop, pollMessage, react, react, react, react, receive, receive, receive, run, send, setParallelGroup, scheduleLoop, silentStart, start, stop, sweepNextMessage, takeMessage, takeMessage, terminate

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

getSender, getSenders, reply, replyIfExists, runEnhancedWithRepliesOnMessages

Methods inherited from class groovyx.gpars.actor.Actor

createActorMessage, createRemoteHandle, deregisterCurrentActorWithThread, getJoinLatch, getParallelGroup, handleException, handleInterrupt, handleTimeout, isActorThread, join, join, join, join, onStop, registerCurrentActorWithThread, sendAndContinue, 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

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

body

private groovy.lang.Closure body

Constructor Detail

SingleRunActor

public SingleRunActor()

Sets the default Dataflow Concurrency actor group on the actor.

Method Detail

act

protected void act()

Description copied from class: AbstractPooledActor

This method represents the body of the actor. It is called upon actor's start and can exit either normally by return or due to actor being stopped through the stop() method, which cancels the current actor action. Provides an extension point for subclasses to provide their custom Actor's message handling code.

Specified by:

act in class AbstractPooledActor

setBody

public void setBody(groovy.lang.Closure body)