positive integer indicates the dispatcher will only process so much messages at a time from the mailbox, without checking the mailboxes of other actors. Zero or negative means the dispatcher always continues until the mailbox is empty. Larger values (or zero or negative) increase throughput, smaller values increase fairness
Attaches the specified actor instance to this dispatcher, which includes scheduling it to run for the first time (Create() is expected to have been enqueued by the ActorCell upon mailbox creation).
Attaches the specified actor instance to this dispatcher, which includes scheduling it to run for the first time (Create() is expected to have been enqueued by the ActorCell upon mailbox creation).
Creates and returns a mailbox for the given actor.
Creates and returns a mailbox for the given actor.
Detaches the specified actor instance from this dispatcher
Detaches the specified actor instance from this dispatcher
Will be called when the dispatcher is to queue an invocation for execution
Will be called when the dispatcher is to queue an invocation for execution
Submits the runnable for execution
Submits the runnable for execution
Identifier of this dispatcher, corresponds to the full key of the dispatcher configuration.
Identifier of this dispatcher, corresponds to the full key of the dispatcher configuration.
If you override it, you must call it.
If you override it, you must call it. But only ever once. See "attach" for only invocation.
Returns if it was registered
Returns if it was registered
Failed tasks should call reportFailure to let the ExecutionContext log the problem or whatever is appropriate for the implementation.
Failed tasks should call reportFailure to let the ExecutionContext log the problem or whatever is appropriate for the implementation.
Called one time every time an actor is detached from this dispatcher and this dispatcher has no actors left attached Must be idempotent
Called one time every time an actor is detached from this dispatcher and this dispatcher has no actors left attached Must be idempotent
When the dispatcher no longer has any actors registered, how long will it wait until it shuts itself down, defaulting to your akka configs "akka.
When the dispatcher no longer has any actors registered, how long will it wait until it shuts itself down, defaulting to your akka configs "akka.actor.default-dispatcher.shutdown-timeout" or default specified in reference.conf
After the call to this method, the dispatcher mustn't begin any new message processing for the specified reference
After the call to this method, the dispatcher mustn't begin any new message processing for the specified reference
Will be called when the dispatcher is to queue an invocation for execution
Will be called when the dispatcher is to queue an invocation for execution
positive integer indicates the dispatcher will only process so much messages at a time from the mailbox, without checking the mailboxes of other actors.
positive integer indicates the dispatcher will only process so much messages at a time from the mailbox, without checking the mailboxes of other actors. Zero or negative means the dispatcher always continues until the mailbox is empty. Larger values (or zero or negative) increase throughput, smaller values increase fairness
If you override it, you must call it.
If you override it, you must call it. But only ever once. See "detach" for the only invocation
The event-based
binds a set of Actors to a thread pool backed up by aDispatcher
BlockingQueue
.The preferred way of creating dispatchers is to define configuration of it and use the the
lookup
method in Dispatchers.