org.codehaus.gpars

groovyx.gpars.activeobject
[Java] Class InternalActor

java.lang.Object
  groovyx.gpars.serial.WithSerialId
      groovyx.gpars.actor.impl.MessageStream
          groovyx.gpars.actor.Actor
              groovyx.gpars.actor.AbstractLoopingActor
                  groovyx.gpars.activeobject.InternalActor

@java.lang.SuppressWarnings});
public final class InternalActor
extends AbstractLoopingActor

Backs active objects and invokes all object's active methods.

Authors:
Vaclav Pech


Field Summary
static java.lang.String METHOD_NAME_PREFIX

private static java.lang.Object[] No_ARGS

private static long serialVersionUID

 
Fields inherited from class AbstractLoopingActor
core, currentSender, currentTimerTask, serialVersionUID, stoppedFlag, terminatedFlag, terminatingFlag, timeoutCounter
 
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
InternalActor()

 
Method Summary
static InternalActor create(java.lang.Object groupId)

private static java.lang.Object handleCurrentMessage(java.lang.Object msg)

void onMessage(java.lang.Object[] msg)

DataflowVariable submit(java.lang.Object... args)

java.lang.Object submitAndWait(java.lang.Object... args)

Handles incoming messages

 
Methods inherited from class AbstractLoopingActor
cancelCurrentTimeoutTask, doStart, getCore, getSender, hasBeenStopped, initialize, isActive, isFair, makeFair, reply, replyIfExists, runEnhancedWithoutRepliesOnMessages, send, setParallelGroup, setTimeout, silentStart, start, stop, sweepNextMessage, 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, sendAndPromise, 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

METHOD_NAME_PREFIX

public static final java.lang.String METHOD_NAME_PREFIX


No_ARGS

private static final java.lang.Object[] No_ARGS


serialVersionUID

private static final long serialVersionUID


 
Constructor Detail

InternalActor

public InternalActor()


 
Method Detail

create

public static InternalActor create(java.lang.Object groupId)


handleCurrentMessage

@java.lang.SuppressWarnings
private static java.lang.Object handleCurrentMessage(java.lang.Object msg)


onMessage

@java.lang.SuppressWarningsfinal Object[] args = params.length > 2 ? Arrays.copyOfRange(params, 2, params.length) : No_ARGS;
public void onMessage(java.lang.Object[] msg)


submit

DataflowVariable submit(java.lang.Object... args)


submitAndWait

@java.lang.SuppressWarnings({"unchecked", "MethodMayBeStatic"})
java.lang.Object submitAndWait(java.lang.Object... args)
Handles incoming messages
Parameters:
msg - The message representing the requested method call


 

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