|
|||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |
Interface Summary | |
---|---|
BoundedDequeBasedMessageQueueSemantics | BoundedMessageQueueSemantics adds bounded semantics to a DequeBasedMessageQueue, i.e. blocking enqueue with timeout |
BoundedMessageQueueSemantics | BoundedMessageQueueSemantics adds bounded semantics to a QueueBasedMessageQueue, i.e. blocking enqueue with timeout |
DequeBasedMessageQueue | 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 | Function0 without the fun stuff (mostly for the sake of the Java API side of things) |
ExecutorServiceFactoryProvider | Generic way to specify an ExecutorService to a Dispatcher, create it with the given name if desired |
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. |
QueueBasedMessageQueue | A QueueBasedMessageQueue is a MessageQueue backed by a java.util.Queue |
UnboundedDequeBasedMessageQueueSemantics | UnboundedDequeBasedMessageQueueSemantics adds unbounded semantics to a DequeBasedMessageQueue, i.e. a non-blocking enqueue and dequeue. |
UnboundedMessageQueueSemantics | UnboundedMessageQueueSemantics adds unbounded semantics to a QueueBasedMessageQueue, i.e. a non-blocking enqueue and dequeue. |
Class Summary | |
---|---|
BalancingDispatcher | An executor based event driven dispatcher which will try to redistribute work from busy actors to idle actors. |
BalancingDispatcherConfigurator | Configurator for creating BalancingDispatcher . |
BoundedDequeBasedMailbox | BoundedDequeBasedMailbox is an bounded MailboxType, backed by a Deque. |
BoundedDequeBasedMailbox$ | |
BoundedMailbox | BoundedMailbox is the default bounded MailboxType used by Akka Actors. |
BoundedMailbox$ | |
BoundedPriorityMailbox | BoundedPriorityMailbox is a bounded mailbox that allows for priorization of its contents. |
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$ | 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.MailboxExecutionTask | 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. |
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 | |
MessageDispatcherConfigurator | Base class to be used for hooking in new dispatchers into Dispatchers. |
MonitorableThreadFactory | |
MonitorableThreadFactory$ | |
NullMessage | This message is sent directly after the Supervise system message in order to form a barrier wrt. the first real message sent by the child, so that e.g. |
NullMessage$ | This message is sent directly after the Supervise system message in order to form a barrier wrt. the first real message sent by the child, so that e.g. |
OnComplete<T> | Callback for when a Future is completed with either failure or a success SAM (Single Abstract Method) class Java API |
OnFailure | Callback for when a Future is completed with a failure SAM (Single Abstract Method) class Java API |
OnSuccess<T> | Callback for when a Future is completed successfully SAM (Single Abstract Method) class Java API |
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. |
TaskInvocation | |
TaskInvocation$ | |
ThreadPoolConfig | A small configuration DSL to create ThreadPoolExecutors that can be provided as an ExecutorServiceFactoryProvider to Dispatcher |
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$ | |
UnboundedMailbox | UnboundedMailbox is the default unbounded MailboxType used by Akka Actors. |
UnboundedMailbox$ | |
UnboundedPriorityMailbox | UnboundedPriorityMailbox is an unbounded mailbox that allows for priorization of its contents. |
|
|||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |