Package akka.dispatch

Interface Summary

Batchable	All Batchables are automatically batched when submitted to a BatchingExecutor
BatchingExecutor	Mixin trait for an Executor which groups multiple nested Runnable.run() calls into a single Runnable passed to the original Executor.
BoundedDequeBasedMessageQueue	BoundedMessageQueueSemantics adds bounded semantics to a DequeBasedMessageQueue, i.e.
BoundedDequeBasedMessageQueueSemantics
BoundedMessageQueueSemantics	BoundedMessageQueueSemantics adds bounded semantics to a QueueBasedMessageQueue, i.e.
BoundedQueueBasedMessageQueue
CachingConfig.PathEntry
DefaultSystemMessageQueue	INTERNAL API
DequeBasedMessageQueue
DequeBasedMessageQueueSemantics	DequeBasedMessageQueue refines QueueBasedMessageQueue to be backed by a java.util.Deque.
DispatcherPrerequisites	DispatcherPrerequisites represents useful contextual pieces when constructing a MessageDispatcher
ExecutorServiceDelegate	As the name says
ExecutorServiceFactory
ExecutorServiceFactoryProvider
LoadMetrics	INTERNAL API
MailboxType	MailboxType is a factory to create MessageQueues for an optionally provided ActorContext.
MessageQueue	A MessageQueue is one of the core components in forming an Akka Mailbox.
MultipleConsumerSemantics	This is a marker trait for message queues which support multiple consumers, as is required by the BalancingDispatcher.
ProducesMessageQueue<T extends MessageQueue>
QueueBasedMessageQueue	A QueueBasedMessageQueue is a MessageQueue backed by a java.util.Queue.
RequiresMessageQueue<T>	Trait to signal that an Actor requires a certain type of message queue semantics.
SystemMessageQueue	INTERNAL API
UnboundedDequeBasedMessageQueue	UnboundedDequeBasedMessageQueueSemantics adds unbounded semantics to a DequeBasedMessageQueue, i.e.
UnboundedDequeBasedMessageQueueSemantics
UnboundedMessageQueueSemantics	UnboundedMessageQueueSemantics adds unbounded semantics to a QueueBasedMessageQueue, i.e.
UnboundedQueueBasedMessageQueue

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$