public class BalancingDispatcher extends Dispatcher
lookup
method in Dispatchers
.
BalancingDispatcher
,
Dispatchers
Constructor and Description |
---|
BalancingDispatcher(MessageDispatcherConfigurator _configurator,
java.lang.String _id,
int throughput,
scala.concurrent.duration.Duration throughputDeadlineTime,
MailboxType _mailboxType,
ExecutorServiceFactoryProvider _executorServiceFactoryProvider,
scala.concurrent.duration.FiniteDuration _shutdownTimeout,
boolean attemptTeamWork) |
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.
|
protected akka.dispatch.Mailbox |
createMailbox(akka.actor.Cell actor,
MailboxType mailboxType)
INTERNAL API
|
protected void |
dispatch(akka.actor.ActorCell receiver,
Envelope invocation)
INTERNAL API
|
void |
execute(java.lang.Runnable runnable) |
MessageQueue |
messageQueue()
INTERNAL API
|
protected void |
register(akka.actor.ActorCell actor)
If you override it, you must call it.
|
java.util.concurrent.ConcurrentSkipListSet<akka.actor.ActorCell> |
team()
INTERNAL API
|
protected void |
teamWork() |
protected void |
unregister(akka.actor.ActorCell actor)
If you override it, you must call it.
|
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 BalancingDispatcher(MessageDispatcherConfigurator _configurator, java.lang.String _id, int throughput, scala.concurrent.duration.Duration throughputDeadlineTime, MailboxType _mailboxType, ExecutorServiceFactoryProvider _executorServiceFactoryProvider, scala.concurrent.duration.FiniteDuration _shutdownTimeout, boolean attemptTeamWork)
public java.util.concurrent.ConcurrentSkipListSet<akka.actor.ActorCell> team()
public MessageQueue messageQueue()
protected akka.dispatch.Mailbox createMailbox(akka.actor.Cell actor, MailboxType mailboxType)
Dispatcher
createMailbox
in class Dispatcher
protected void register(akka.actor.ActorCell actor)
MessageDispatcher
INTERNAL API
register
in class MessageDispatcher
protected void unregister(akka.actor.ActorCell actor)
MessageDispatcher
INTERNAL API
unregister
in class MessageDispatcher
protected void dispatch(akka.actor.ActorCell receiver, Envelope invocation)
Dispatcher
dispatch
in class Dispatcher
protected void teamWork()
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)