public class PinnedDispatcher extends Dispatcher
The preferred way of creating dispatchers is to define configuration of it and use the
the lookup
method in Dispatchers
.
Constructor and Description |
---|
PinnedDispatcher(MessageDispatcherConfigurator _configurator,
akka.actor.ActorCell _actor,
java.lang.String _id,
scala.concurrent.duration.FiniteDuration _shutdownTimeout,
ThreadPoolConfig _threadPoolConfig) |
Modifier and Type | Method and Description |
---|---|
java.lang.ThreadLocal<scala.collection.immutable.List<java.lang.Runnable>> |
_tasksLocal() |
boolean |
batchable(java.lang.Runnable runnable)
Override this to define which runnables will be batched.
|
void |
execute(java.lang.Runnable runnable) |
protected void |
register(akka.actor.ActorCell actorCell)
If you override it, you must call it.
|
protected void |
unregister(akka.actor.ActorCell actor)
If you override it, you must call it.
|
createMailbox, dispatch, executeTask, executorService, id, registerForExecution, shutdown, shutdownTimeout, systemDispatch, throughput, throughputDeadlineTime, toString
actors, attach, configurator, debug, detach, eventStream, inhabitants, isThroughputDeadlineTimeDefined, mailboxes, printActors, reportFailure, RESCHEDULED, resume, SCHEDULED, suspend, unbatchedExecute, UNSCHEDULED
public PinnedDispatcher(MessageDispatcherConfigurator _configurator, akka.actor.ActorCell _actor, java.lang.String _id, scala.concurrent.duration.FiniteDuration _shutdownTimeout, ThreadPoolConfig _threadPoolConfig)
protected void register(akka.actor.ActorCell actorCell)
MessageDispatcher
INTERNAL API
register
in class MessageDispatcher
protected void unregister(akka.actor.ActorCell actor)
MessageDispatcher
INTERNAL API
unregister
in class MessageDispatcher
public java.lang.ThreadLocal<scala.collection.immutable.List<java.lang.Runnable>> _tasksLocal()
public void execute(java.lang.Runnable runnable)
execute
in interface java.util.concurrent.Executor
public boolean batchable(java.lang.Runnable runnable)