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
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 |
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 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() |
remoteHost
private final RemoteHost remoteHost
-
serialVersionUID
private static final long serialVersionUID
-
Actor.RemoteActor
public Actor.RemoteActor(SerialContext host, DataflowExpression jointLatch)
-
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.