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

groovyx.gpars.actor
Class Actor.RemoteActor

java.lang.Object
  groovyx.gpars.serial.WithSerialId
      groovyx.gpars.actor.impl.MessageStream
          groovyx.gpars.actor.Actor
              groovyx.gpars.actor.Actor.RemoteActor
All Implemented Interfaces:
RemoteSerialized
class Actor.RemoteActor
extends Actor
Nested Class Summary
class Actor.RemoteActor.StopActorMsg

class Actor.RemoteActor.TerminateActorMsg

 
Field Summary
private RemoteHost remoteHost

private static long serialVersionUID

 
Fields inherited from class Actor
ACTOR_HAS_ALREADY_BEEN_STARTED, START_MESSAGE, STOP_MESSAGE, TERMINATE_MESSAGE, TIMEOUT_MESSAGE, currentThread, parallelGroup, timer
 
Constructor Summary
Actor.RemoteActor(SerialContext host, DataFlowExpression jointLatch)

 
Method Summary
protected boolean hasBeenStopped()

boolean isActive()

MessageStream send(java.lang.Object message)

Actor silentStart()

Actor start()

Actor stop()

protected ActorMessage sweepNextMessage()

Actor 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
 

Field Detail

remoteHost

private final RemoteHost remoteHost

serialVersionUID

private static final long serialVersionUID

 
Constructor Detail

Actor.RemoteActor

public Actor.RemoteActor(SerialContext host, DataFlowExpression jointLatch)

 
Method Detail

hasBeenStopped

@Override
protected boolean hasBeenStopped()

isActive

@Override
public boolean isActive()

send

@SuppressWarnings({"AssignmentToMethodParameter"})
@Override
public MessageStream send(java.lang.Object message)

silentStart

@Override
public Actor silentStart()

start

@Override
public Actor start()

stop

@Override
public Actor stop()

sweepNextMessage

@Override
protected ActorMessage sweepNextMessage()

terminate

@Override
public Actor terminate()

 

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