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 |
---|---|
protected Mailbox |
createMailbox(Cell actor,
MailboxType mailboxType)
INTERNAL API
|
protected void |
dispatch(ActorCell receiver,
Envelope invocation)
INTERNAL API
|
MessageQueue |
messageQueue()
INTERNAL API
|
protected void |
register(ActorCell actor)
If you override it, you must call it.
|
java.util.concurrent.ConcurrentSkipListSet<ActorCell> |
team()
INTERNAL API
|
protected void |
teamWork() |
protected void |
unregister(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, resubmitOnBlock, resume, SCHEDULED, suspend, unbatchedExecute, UNSCHEDULED
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
batchable, execute
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<ActorCell> team()
public MessageQueue messageQueue()
protected Mailbox createMailbox(Cell actor, MailboxType mailboxType)
Dispatcher
createMailbox
in class Dispatcher
actor
- (undocumented)mailboxType
- (undocumented)protected void register(ActorCell actor)
MessageDispatcher
INTERNAL API
register
in class MessageDispatcher
actor
- (undocumented)protected void unregister(ActorCell actor)
MessageDispatcher
INTERNAL API
unregister
in class MessageDispatcher
actor
- (undocumented)protected void dispatch(ActorCell receiver, Envelope invocation)
Dispatcher
dispatch
in class Dispatcher
receiver
- (undocumented)invocation
- (undocumented)protected void teamWork()