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

groovyx.gpars.actor.impl
Class RunnableBackedPooledActor

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.actor.impl.RunnableBackedPooledActor

@Deprecated
class RunnableBackedPooledActor
extends AbstractPooledActor

Utility class to implement AbstractPooledActor backed by any Runnable (including Closure)

Authors:
Alex Tkachman, Vaclav Pech

Nested Class Summary
class RunnableBackedPooledActor.RunnableBackedPooledActorDelegate

 
Field Summary
private java.lang.Runnable action

private static long serialVersionUID

 
Fields inherited from class SequentialProcessingActor
S_ACTIVE_MASK, S_FINISHED_MASK, S_FINISHING_MASK, S_NOT_STARTED, S_RUNNING, S_STOPPED, S_STOPPING, S_STOP_TERMINATE_MASK, S_TERMINATED, S_TERMINATING, afterLoopCode, loopCode, loopCondition, stopFlag, stopFlagUpdater
 
Fields inherited from class ReplyingMessageStream
obj2Sender
 
Fields inherited from class Actor
ACTOR_HAS_ALREADY_BEEN_STARTED, START_MESSAGE, STOP_MESSAGE, TERMINATE_MESSAGE, TIMEOUT_MESSAGE, currentThread, parallelGroup, timer
 
Constructor Summary
RunnableBackedPooledActor(java.lang.Runnable handler)

 
Method Summary
protected void act()

protected void setAction(java.lang.Runnable handler)

 
Methods inherited from class AbstractPooledActor
act, handleStart, receive, receive, receive, receiveImpl, receiveImpl
 
Methods inherited from class SequentialProcessingActor
checkStopTerminate, handleTermination, hasBeenStopped, isActive, loop, loop, loop, loop, loop, pollMessage, react, react, react, react, receive, receive, receive, receiveImpl, receiveImpl, run, runReaction, scheduleLoop, send, setParallelGroup, silentStart, start, stop, sweepNextMessage, takeMessage, takeMessage, terminate
 
Methods inherited from class ReplyingMessageStream
getSender, getSenders, reply, replyIfExists, runEnhancedWithRepliesOnMessages
 
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

action

private java.lang.Runnable action

serialVersionUID

private static final long serialVersionUID

 
Constructor Detail

RunnableBackedPooledActor

public RunnableBackedPooledActor(java.lang.Runnable handler)

 
Method Detail

act

@SuppressWarnings("rawtypes")
@Override
protected final void act()

setAction

protected final void setAction(java.lang.Runnable handler)

 

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