org.codehaus.gpars

Package groovyx.gpars.actor.impl

 

Class Summary
DDAClosure Creates a DDA closure to invoke appropriate actor's message handlers based on message runtime type
MessageStream Represents a stream of messages and forms the base class for actors
MessageStream.RemoteMessageStream
MessageStream.ResultWaiter Represents a pending request for a reply from an actor.
MessageStream.SendTo
ReplyCategory Enhances objects with the ability to send replies and detect message originators.
ReplyingMessageStream @author Alex Tkachman, Vaclav Pech
RunnableBackedPooledActor Utility class to implement AbstractPooledActor backed by any Runnable (including Closure)
RunnableBackedPooledActor.RunnableBackedPooledActorDelegate
SequentialProcessingActor @author Alex Tkachman, Vaclav Pech
SequentialProcessingActor.MultiMessageReaction Enables multiple argument closures to be passed to react().
SequentialProcessingActor.Node Represents an element in the message queue.
SequentialProcessingActor.Reaction Buffers messages for the next continuation of an event-driven actor, handles timeouts and no-param continuations.
 


Exception Summary
ActorContinuationException An exception indicating end of a work chunk (ActorAction) allowing other ActorAction to get scheduled.
ActorException Pooled actors need to simulate continuations to create stacktrace-less chunks of work (ActorActions) to assign to the threads from the pool.
ActorReplyException Indicates problems sending replies to actors.
ActorStopException An exception indicating Actor stopping request.
ActorTerminationException An exception indicating Actor termination request.
ActorTimeoutException An exception indicating Actor react timeout.
 


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