org.codehaus.gpars

groovyx.gpars.actor
[Java] 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

public static class Actor.RemoteActor
extends Actor

Nested Class Summary
static class Actor.RemoteActor.StopActorMsg

static class Actor.RemoteActor.TerminateActorMsg

 
Field Summary
private RemoteHost remoteHost

private static long serialVersionUID

 
Fields inherited from class Actor
ACTOR_HAS_ALREADY_BEEN_STARTED, AFTER_START, CANNOT_SEND_REPLIES_NO_SENDER_HAS_BEEN_REGISTERED, EMPTY_ARGUMENTS, ON_DELIVERY_ERROR, RESPONDS_TO, START_MESSAGE, STOP_MESSAGE, TERMINATE_MESSAGE, TIMEOUT, TIMEOUT_MESSAGE, currentActorPerThread, currentThread, joinLatch, onStop, parallelGroup, serialVersionUID, timer
 
Fields inherited from class MessageStream
serialVersionUID
 
Fields inherited from class WithSerialId
serialHandle, serialVersionUID
 
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
callDynamic, 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
 
Methods inherited from class java.lang.Object
java.lang.Object#wait(long), java.lang.Object#wait(), java.lang.Object#wait(long, int), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll()
 

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.