An executor based event driven dispatcher which will try to redistribute work from busy actors to idle actors.
Configurator for creating akka.dispatch.BalancingDispatcher.
BoundedDequeBasedMailbox is an bounded MailboxType, backed by a Deque.
BoundedMessageQueueSemantics adds bounded semantics to a DequeBasedMessageQueue, i.
BoundedMailbox is the default bounded MailboxType used by Akka Actors.
BoundedMessageQueueSemantics adds bounded semantics to a QueueBasedMessageQueue, i.
BoundedPriorityMailbox is a bounded mailbox that allows for priorization of its contents.
DequeBasedMessageQueue refines QueueBasedMessageQueue to be backed by a java.
The event-based
binds a set of Actors to a thread pool backed up by a
Dispatcher
BlockingQueue
.
Configurator for creating akka.dispatch.Dispatcher.
DispatcherPrerequisites represents useful contextual pieces when constructing a MessageDispatcher
Dispatchers are to be defined in configuration to allow for tuning for different environments.
An ExecutorServiceConfigurator is a class that given some prerequisites and a configuration can create instances of ExecutorService
As the name says
Function0 without the fun stuff (mostly for the sake of the Java API side of things)
Generic way to specify an ExecutorService to a Dispatcher, create it with the given name if desired
Callback for the Future.
MailboxType is a factory to create MessageQueues for an optionally provided ActorContext.
Callback for the Future.
Base class to be used for hooking in new dispatchers into Dispatchers.
A MessageQueue is one of the core components in forming an Akka Mailbox.
Callback for when a Future is completed with either failure or a success SAM (Single Abstract Method) class
Callback for when a Future is completed with a failure SAM (Single Abstract Method) class
Callback for when a Future is completed successfully SAM (Single Abstract Method) class
Dedicates a unique thread for each actor passed in as reference.
Configurator for creating akka.dispatch.PinnedDispatcher.
A PriorityGenerator is a convenience API to create a Comparator that orders the messages of a PriorityDispatcher
A QueueBasedMessageQueue is a MessageQueue backed by a java.
Callback for the Future.
The RejectedExecutionHandler used by Akka, it improves on CallerRunsPolicy by throwing a RejectedExecutionException if the executor isShutdown.
A small configuration DSL to create ThreadPoolExecutors that can be provided as an ExecutorServiceFactoryProvider to Dispatcher
A DSL to configure and create a MessageDispatcher with a ThreadPoolExecutor
UnboundedDequeBasedMailbox is an unbounded MailboxType, backed by a Deque.
UnboundedDequeBasedMessageQueueSemantics adds unbounded semantics to a DequeBasedMessageQueue, i.
UnboundedMailbox is the default unbounded MailboxType used by Akka Actors.
UnboundedMessageQueueSemantics adds unbounded semantics to a QueueBasedMessageQueue, i.
UnboundedPriorityMailbox is an unbounded mailbox that allows for priorization of its contents.
ExecutionContexts is the Java API for ExecutionContexts
Java API (not recommended): Callback for the Future.
Futures is the Java API for Futures and Promises
This message is sent directly after the Supervise system message in order to form a barrier wrt.
This class contains bridge classes between Scala and Java.