Class Summary |
AbstractNodeQueue<T> |
Lock-free MPSC linked queue implementation based on Dmitriy Vyukov's non-intrusive MPSC queue:
http://www.1024cores.net/home/lock-free-algorithms/queues/non-intrusive-mpsc-node-based-queue
This queue could be wait-free (i.e. |
AbstractNodeQueue.Node<T> |
|
BalancingDispatcher |
An executor based event driven dispatcher which will try to redistribute work from busy actors to idle actors. |
BalancingDispatcherConfigurator |
Configurator for creating BalancingDispatcher . |
BalancingDispatcherConfigurator$ |
INTERNAL API |
BatchingExecutor.AbstractBatch |
|
BatchingExecutor.Batch |
|
BatchingExecutor.BlockableBatch |
|
BoundedDequeBasedMailbox |
BoundedDequeBasedMailbox is an bounded MailboxType, backed by a Deque. |
BoundedDequeBasedMailbox.MessageQueue |
|
BoundedDequeBasedMailbox$ |
|
BoundedMailbox |
BoundedMailbox is the default bounded MailboxType used by Akka Actors. |
BoundedMailbox.MessageQueue |
|
BoundedMailbox$ |
|
BoundedPriorityMailbox |
BoundedPriorityMailbox is a bounded mailbox that allows for prioritization of its contents. |
BoundedPriorityMailbox.MessageQueue |
|
BoundedPriorityMailbox$ |
|
CachingConfig |
INTERNAL API |
CachingConfig.StringPathEntry |
|
CachingConfig.StringPathEntry$ |
|
CachingConfig.ValuePathEntry |
|
CachingConfig.ValuePathEntry$ |
|
CachingConfig$ |
INTERNAL API |
DefaultDispatcherPrerequisites |
INTERNAL API |
DefaultDispatcherPrerequisites$ |
|
DefaultExecutorServiceConfigurator |
|
Dispatcher |
The event-based Dispatcher binds a set of Actors to a thread pool backed up by a
BlockingQueue . |
DispatcherConfigurator |
Configurator for creating Dispatcher . |
Dispatchers |
Dispatchers are to be defined in configuration to allow for tuning
for different environments. |
Dispatchers$ |
|
Envelope |
|
Envelope$ |
|
ExecutionContexts |
ExecutionContexts is the Java API for ExecutionContexts |
ExecutionContexts.sameThreadExecutionContext$ |
WARNING: Not A General Purpose ExecutionContext! |
ExecutionContexts$ |
ExecutionContexts is the Java API for ExecutionContexts |
ExecutorServiceConfigurator |
An ExecutorServiceConfigurator is a class that given some prerequisites and a configuration can create instances of ExecutorService |
Filter |
Java API (not recommended):
Callback for the Future.filter operation that creates a new Future which will
conditionally contain the success of another Future. |
Filter$ |
Java API (not recommended):
Callback for the Future.filter operation that creates a new Future which will
conditionally contain the success of another Future. |
Foreach<T> |
Callback for the Future.foreach operation that will be invoked if the Future that this callback
is registered on becomes completed with a success. |
ForkJoinExecutorConfigurator |
|
ForkJoinExecutorConfigurator.AkkaForkJoinPool |
INTERNAL AKKA USAGE ONLY |
ForkJoinExecutorConfigurator.AkkaForkJoinTask |
INTERNAL AKKA USAGE ONLY |
ForkJoinExecutorConfigurator$ |
|
Futures |
Futures is the Java API for Futures and Promises |
Futures$ |
Futures is the Java API for Futures and Promises |
japi |
This class contains bridge classes between Scala and Java. |
japi.BooleanFunctionBridge<T> |
|
japi.CallbackBridge<T> |
|
japi.RecoverBridge<T> |
|
japi.UnitFunctionBridge<T> |
|
japi$ |
This class contains bridge classes between Scala and Java. |
Mailbox |
Mailbox and InternalMailbox is separated in two classes because ActorCell is needed for implementation,
but can't be exposed to user defined mailbox subclasses. |
Mailbox$ |
INTERNAL API |
Mailboxes |
|
Mailboxes$ |
|
Mapper<T,R> |
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. |
MessageDispatcher |
|
MessageDispatcher$ |
INTERNAL API |
MessageDispatcherConfigurator |
Base class to be used for hooking in new dispatchers into Dispatchers. |
MonitorableThreadFactory |
|
MonitorableThreadFactory.AkkaForkJoinWorkerThread |
|
MonitorableThreadFactory$ |
|
NodeMessageQueue |
|
OnComplete<T> |
Callback for when a Future is completed with either failure or a success
SAM (Single Abstract Method) class |
OnFailure |
Callback for when a Future is completed with a failure
SAM (Single Abstract Method) class |
OnSuccess<T> |
Callback for when a Future is completed successfully
SAM (Single Abstract Method) class |
PinnedDispatcher |
Dedicates a unique thread for each actor passed in as reference. |
PinnedDispatcherConfigurator |
Configurator for creating PinnedDispatcher . |
PriorityGenerator |
A PriorityGenerator is a convenience API to create a Comparator that orders the messages of a
PriorityDispatcher |
PriorityGenerator$ |
|
Recover<T> |
Callback for the Future.recover operation that conditionally turns failures into successes. |
SaneRejectedExecutionHandler |
The RejectedExecutionHandler used by Akka, it improves on CallerRunsPolicy
by throwing a RejectedExecutionException if the executor isShutdown. |
SingleConsumerOnlyUnboundedMailbox |
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. |
SingleConsumerOnlyUnboundedMailbox$ |
|
TaskInvocation |
|
TaskInvocation$ |
|
ThreadPoolConfig |
|
ThreadPoolConfig$ |
|
ThreadPoolConfigBuilder |
A DSL to configure and create a MessageDispatcher with a ThreadPoolExecutor |
ThreadPoolConfigBuilder$ |
|
ThreadPoolExecutorConfigurator |
|
UnboundedDequeBasedMailbox |
UnboundedDequeBasedMailbox is an unbounded MailboxType, backed by a Deque. |
UnboundedDequeBasedMailbox.MessageQueue |
|
UnboundedDequeBasedMailbox$ |
|
UnboundedMailbox |
UnboundedMailbox is the default unbounded MailboxType used by Akka Actors. |
UnboundedMailbox.MessageQueue |
|
UnboundedMailbox$ |
|
UnboundedPriorityMailbox |
UnboundedPriorityMailbox is an unbounded mailbox that allows for prioritization of its contents. |
UnboundedPriorityMailbox.MessageQueue |
|
UnboundedPriorityMailbox$ |
|