An executor based event driven dispatcher which will try to redistribute work from busy actors to idle actors.
Configurator for creating BalancingDispatcher.
Extend me to provide the comparator
The default concrete Future implementation.
The event-based
binds a set of Actors to a thread pool backed up by a
Dispatcher
BlockingQueue
.
Configurator for creating Dispatcher.
Dispatchers are to be defined in configuration to allow for tuning for different environments.
An ExecutionContext is essentially the same thing as a java.
Union interface since Java does not support union types
Union interface since Java does not support union types
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.
Trait representing a value that may not have been computed yet.
An already completed Future is seeded with it's result at creation, is useful for when you are participating in a Future-composition but you already have a value to contribute.
Mailbox configuration.
Callback for the Future.
Base class to be used for hooking in new dispatchers into Dispatchers.
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 PinnedDispatcher.
A PriorityGenerator is a convenience API to create a Comparator that orders the messages of a PriorityDispatcher
Essentially this is the Promise (or write-side) of a Future (read-side).
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
It's a case class for Java (new UnboundedMailbox)
Extend me to provide the comparator
(Since version 2.0.2) Will become private[akka] in 2.1, this is not user-api
(Since version 2.0.2) Will become private[akka] in 2.1, this is not user-api
(Since version 2.0) Await throws java.util.concurrent.TimeoutException
(Since version 2.0.2) Will become private[akka] in 2.1, this is not user-api
Some old methods made available through implicit conversion in migration.
(Since version 2.0.2) Was never officially supported or documented, will be removed in Akka 2.1
(Since version 2.0.2) Was never officially supported or documented, will be removed in Akka 2.1
(Since version 2.0.2) Was never officially supported or documented, will be removed in Akka 2.1
(Since version 2.0.2) Will become private[akka] in 2.1, this is not user-api
(Since version 2.0.2) Will become private[akka] in 2.1, this is not user-api
(Since version 2.0.2) Will become private[akka] in 2.1, this is not user-api
(Since version 2.0.2) Will become private[akka] in 2.1, this is not user-api
(Since version 2.0.2) Will become private[akka] in 2.1, this is not user-api
System messages are handled specially: they form their own queue within each actor’s mailbox.
(Since version 2.0.2) Will become private[akka] in 2.1, this is not user-api
(Since version 2.0.2) Will become private[akka] in 2.1, this is not user-api
Java API to create ExecutionContexts
Java API (not recommended): Callback for the Future.
Futures is the Java API for Futures and Promises
This class contains bridge classes between Scala and Java.
(Since version 2.0.2) Will become private[akka] in 2.1, this is not user-api
(Since version 2.0.2) Was never officially supported or documented, will be removed in Akka 2.1
(Since version 2.0.2) Will become private[akka] in 2.1, this is not user-api
(Since version 2.0.2) Will become private[akka] in 2.1, this is not user-api