akka.dispatch
Class PinnedDispatcher
java.lang.Object
akka.dispatch.MessageDispatcher
akka.dispatch.Dispatcher
akka.dispatch.PinnedDispatcher
- All Implemented Interfaces:
- BatchingExecutor, java.util.concurrent.Executor, scala.concurrent.ExecutionContext, scala.concurrent.ExecutionContextExecutor
public class PinnedDispatcher
- extends Dispatcher
Dedicates a unique thread for each actor passed in as reference. Served through its messageQueue.
The preferred way of creating dispatchers is to define configuration of it and use the
the lookup
method in Dispatchers
.
Nested classes/interfaces inherited from interface scala.concurrent.ExecutionContext |
scala.concurrent.ExecutionContext.Implicits$ |
Methods inherited from class akka.dispatch.Dispatcher |
createMailbox, dispatch, executeTask, executorService, id, registerForExecution, shutdown, shutdownTimeout, systemDispatch, throughput, throughputDeadlineTime, toString |
Methods inherited from class akka.dispatch.MessageDispatcher |
actors, attach, configurator, debug, detach, eventStream, inhabitants, isThroughputDeadlineTimeDefined, mailboxes, printActors, reportFailure, RESCHEDULED, resubmitOnBlock, resume, SCHEDULED, suspend, unbatchedExecute, UNSCHEDULED |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface scala.concurrent.ExecutionContext |
execute, prepare |
PinnedDispatcher
public PinnedDispatcher(MessageDispatcherConfigurator _configurator,
ActorCell _actor,
java.lang.String _id,
scala.concurrent.duration.FiniteDuration _shutdownTimeout,
ThreadPoolConfig _threadPoolConfig)
register
protected void register(ActorCell actorCell)
- Description copied from class:
MessageDispatcher
- If you override it, you must call it. But only ever once. See "attach" for only invocation.
INTERNAL API
- Overrides:
register
in class MessageDispatcher
- Parameters:
actorCell
- (undocumented)
unregister
protected void unregister(ActorCell actor)
- Description copied from class:
MessageDispatcher
- If you override it, you must call it. But only ever once. See "detach" for the only invocation
INTERNAL API
- Overrides:
unregister
in class MessageDispatcher
- Parameters:
actor
- (undocumented)