Configurator for creating akka.dispatch.BalancingDispatcher.
BoundedDequeBasedMailbox is an bounded MailboxType, backed by a Deque.
BoundedMessageQueueSemantics adds bounded semantics to a DequeBasedMessageQueue, i.e.
BoundedMailbox is the default bounded MailboxType used by Akka Actors.
BoundedMessageQueueSemantics adds bounded semantics to a QueueBasedMessageQueue, i.e.
BoundedPriorityMailbox is a bounded mailbox that allows for prioritization of its contents.
DequeBasedMessageQueue refines QueueBasedMessageQueue to be backed by a java.util.Deque.
binds a set of Actors to a thread pool backed up by a
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.foreach operation that will be invoked if the Future that this callback is registered on becomes completed with a success.
MailboxType is a factory to create MessageQueues for an optionally provided ActorContext.
Callback for the Future.map and Future.flatMap operations that will be invoked if the Future that this callback is registered on becomes completed with a success.
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.
This is a marker trait for message queues which support multiple consumers, as is required by the BalancingDispatcher.
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.util.Queue.
Callback for the Future.recover operation that conditionally turns failures into successes.
Trait to signal that an Actor requires a certain type of message queue semantics.
The RejectedExecutionHandler used by Akka, it improves on CallerRunsPolicy by throwing a RejectedExecutionException if the executor isShutdown.
SingleConsumerOnlyUnboundedMailbox is a high-performance, multiple producer—single consumer, unbounded MailboxType, with the drawback that you can't have multiple consumers, which rules out using it with BalancingPool (BalancingDispatcher) for instance.
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.e.
UnboundedMailbox is the default unbounded MailboxType used by Akka Actors.
UnboundedMessageQueueSemantics adds unbounded semantics to a QueueBasedMessageQueue, i.e.
UnboundedPriorityMailbox is an unbounded mailbox that allows for prioritization of its contents.
An executor based event driven dispatcher which will try to redistribute work from busy actors to idle actors.
(Since version 2.3) Use BalancingPool instead of BalancingDispatcher
ExecutionContexts is the Java API for ExecutionContexts
Java API (not recommended): Callback for the Future.filter operation that creates a new Future which will conditionally contain the success of another Future.
Futures is the Java API for Futures and Promises
This class contains bridge classes between Scala and Java.