akka.dispatch
Class PinnedDispatcher

java.lang.Object
  extended by akka.dispatch.MessageDispatcher
      extended by akka.dispatch.Dispatcher
          extended by 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 Class Summary
 
Nested classes/interfaces inherited from interface scala.concurrent.ExecutionContext
scala.concurrent.ExecutionContext.Implicits$
 
Constructor Summary
PinnedDispatcher(MessageDispatcherConfigurator _configurator, ActorCell _actor, java.lang.String _id, scala.concurrent.duration.FiniteDuration _shutdownTimeout, ThreadPoolConfig _threadPoolConfig)
           
 
Method Summary
protected  void register(ActorCell actorCell)
          If you override it, you must call it.
protected  void unregister(ActorCell actor)
          If you override it, you must call it.
 
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 akka.dispatch.BatchingExecutor
batchable, execute
 
Methods inherited from interface scala.concurrent.ExecutionContext
execute, prepare
 

Constructor Detail

PinnedDispatcher

public PinnedDispatcher(MessageDispatcherConfigurator _configurator,
                        ActorCell _actor,
                        java.lang.String _id,
                        scala.concurrent.duration.FiniteDuration _shutdownTimeout,
                        ThreadPoolConfig _threadPoolConfig)
Method Detail

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)