Name | Description | Type | Package | Framework |
AbstractBoundedNodeQueue | Lock-free bounded non-blocking multiple-producer single-consumer queue based on the works of: Andriy Plokhotnuyk (https://github. | Class | akka.dispatch | Akka |
|
AbstractBoundedNodeQueue .Node | | Class | akka.dispatch.AbstractBoundedNodeQueue | Akka |
|
AbstractNodeQueue | Lock-free MPSC linked queue implementation based on Dmitriy Vyukov's non-intrusive MPSC queue: http://www. | Class | akka.dispatch | Akka |
|
AbstractNodeQueue .Node | | Class | akka.dispatch.AbstractNodeQueue | Akka |
|
BalancingDispatcher | An executor based event driven dispatcher which will try to redistribute work from busy actors to idle actors. | Class | akka.dispatch | Akka |
|
BalancingDispatcherConfigurator | Configurator for creating BalancingDispatcher. | Class | akka.dispatch | Akka |
|
BalancingDispatcherConfigurator$ | | Class | akka.dispatch | Akka |
|
Batchable | | Interface | akka.dispatch | Akka |
|
BatchingExecutor | Mixin trait for an Executor which groups multiple nested Runnable. | Interface | akka.dispatch | Akka |
|
BatchingExecutor .AbstractBatch | | Class | akka.dispatch.BatchingExecutor | Akka |
|
BatchingExecutor .Batch | | Class | akka.dispatch.BatchingExecutor | Akka |
|
BatchingExecutor .BlockableBatch | | Class | akka.dispatch.BatchingExecutor | Akka |
|
BoundedControlAwareMailbox | BoundedControlAwareMailbox is a bounded MailboxType, that maintains two queues to allow messages that extend ControlMessage to be delivered with priority. | Class | akka.dispatch | Akka |
|
BoundedControlAwareMailbox$ | | Class | akka.dispatch | Akka |
|
BoundedControlAwareMailbox .MessageQueue | | Class | akka.dispatch.BoundedControlAwareMailbox | Akka |
|
BoundedControlAwareMessageQueueSemantics | | Interface | akka.dispatch | Akka |
|
BoundedDequeBasedMailbox | BoundedDequeBasedMailbox is an bounded MailboxType, backed by a Deque. | Class | akka.dispatch | Akka |
|
BoundedDequeBasedMailbox$ | | Class | akka.dispatch | Akka |
|
BoundedDequeBasedMailbox .MessageQueue | | Class | akka.dispatch.BoundedDequeBasedMailbox | Akka |
|
BoundedDequeBasedMessageQueue | BoundedMessageQueueSemantics adds bounded semantics to a DequeBasedMessageQueue, i. | Interface | akka.dispatch | Akka |
|
BoundedDequeBasedMessageQueueSemantics | | Interface | akka.dispatch | Akka |
|
BoundedMailbox | BoundedMailbox is the default bounded MailboxType used by Akka Actors. | Class | akka.dispatch | Akka |
|
BoundedMailbox$ | | Class | akka.dispatch | Akka |
|
BoundedMailbox .MessageQueue | | Class | akka.dispatch.BoundedMailbox | Akka |
|
BoundedMessageQueueSemantics | BoundedMessageQueueSemantics adds bounded semantics to a QueueBasedMessageQueue, i. | Interface | akka.dispatch | Akka |
|
BoundedNodeMessageQueue | Lock-free bounded non-blocking multiple-producer single-consumer queue. | Class | akka.dispatch | Akka |
|
BoundedPriorityMailbox | BoundedPriorityMailbox is a bounded mailbox that allows for prioritization of its contents. | Class | akka.dispatch | Akka |
|
BoundedPriorityMailbox$ | | Class | akka.dispatch | Akka |
|
BoundedPriorityMailbox .MessageQueue | | Class | akka.dispatch.BoundedPriorityMailbox | Akka |
|
BoundedQueueBasedMessageQueue | Try to dequeue the next message from this queue, return null failing that. | Interface | akka.dispatch | Akka |
|
BoundedStablePriorityMailbox | BoundedStablePriorityMailbox is a bounded mailbox that allows for prioritization of its contents. | Class | akka.dispatch | Akka |
|
BoundedStablePriorityMailbox$ | | Class | akka.dispatch | Akka |
|
BoundedStablePriorityMailbox .MessageQueue | | Class | akka.dispatch.BoundedStablePriorityMailbox | Akka |
|
CachingConfig | A CachingConfig is a Config that wraps another Config and is used to cache path lookup and string retrieval, which we happen to do a lot in some critical paths of the actor creation and mailbox | Class | akka.dispatch | Akka |
|
CachingConfig$ | | Class | akka.dispatch | Akka |
|
CachingConfig .PathEntry | com. | Interface | akka.dispatch.CachingConfig | Akka |
|
CachingConfig .StringPathEntry | | Class | akka.dispatch.CachingConfig | Akka |
|
CachingConfig .StringPathEntry$ | | Class | akka.dispatch.CachingConfig | Akka |
|
CachingConfig .ValuePathEntry | | Class | akka.dispatch.CachingConfig | Akka |
|
CachingConfig .ValuePathEntry$ | | Class | akka.dispatch.CachingConfig | Akka |
|
ControlAwareMessageQueueSemantics | ControlAwareMessageQueue handles messages that extend ControlMessage with priority. | Interface | akka.dispatch | Akka |
|
Create | | Class | akka.dispatch.sysmsg | Akka |
|
Create$ | | Class | akka.dispatch.sysmsg | Akka |
|
DeathWatchNotification | | Class | akka.dispatch.sysmsg | Akka |
|
DeathWatchNotification$ | | Class | akka.dispatch.sysmsg | Akka |
|
DefaultDispatcherPrerequisites | | Class | akka.dispatch | Akka |
|
DefaultDispatcherPrerequisites$ | | Class | akka.dispatch | Akka |
|
DefaultExecutorServiceConfigurator | | Class | akka.dispatch | Akka |
|
DefaultSystemMessageQueue | | Interface | akka.dispatch | Akka |
|
DequeBasedMessageQueue | | Interface | akka.dispatch | Akka |
|
DequeBasedMessageQueueSemantics | DequeBasedMessageQueue refines QueueBasedMessageQueue to be backed by a java. | Interface | akka.dispatch | Akka |
|
Dispatcher | The event-based Dispatcher binds a set of Actors to a thread pool backed up by a The preferred way of creating dispatchers is to define configuration of it and use the | Class | akka.dispatch | Akka |
|
DispatcherConfigurator | Configurator for creating Dispatcher. | Class | akka.dispatch | Akka |
|
DispatcherPrerequisites | DispatcherPrerequisites represents useful contextual pieces when constructing a MessageDispatcher | Interface | akka.dispatch | Akka |
|
Dispatchers | Dispatchers are to be defined in configuration to allow for tuning for different environments. | Class | akka.dispatch | Akka |
|
Dispatchers$ | | Class | akka.dispatch | Akka |
|
EarliestFirstSystemMessageList | Value class supporting list operations on system messages. | Class | akka.dispatch.sysmsg | Akka |
|
EarliestFirstSystemMessageList$ | | Class | akka.dispatch.sysmsg | Akka |
|
Envelope | | Class | akka.dispatch | Akka |
|
Envelope$ | | Class | akka.dispatch | Akka |
|
ExecutionContexts | | Class | akka.dispatch | Akka |
|
ExecutionContexts$ | | Class | akka.dispatch | Akka |
|
ExecutionContexts .sameThreadExecutionContext$ | WARNING: Not A General Purpose ExecutionContext! This is an execution context which runs everything on the calling thread. | Class | akka.dispatch.ExecutionContexts | Akka |
|
ExecutorServiceConfigurator | | Class | akka.dispatch | Akka |
|
ExecutorServiceDelegate | java. | Interface | akka.dispatch | Akka |
|
ExecutorServiceFactory | createExecutorServicejava. | Interface | akka.dispatch | Akka |
|
ExecutorServiceFactoryProvider | java. | Interface | akka.dispatch | Akka |
|
Failed | | Class | akka.dispatch.sysmsg | Akka |
|
Failed$ | | Class | akka.dispatch.sysmsg | Akka |
|
Filter | Java API (not recommended): Callback for the Future. | Class | akka.dispatch | Akka |
|
Filter$ | Java API (not recommended): Callback for the Future. | Class | akka.dispatch | Akka |
|
Foreach | Callback for the Future. | Class | akka.dispatch | Akka |
|
ForkJoinExecutorConfigurator | | Class | akka.dispatch | Akka |
|
ForkJoinExecutorConfigurator$ | | Class | akka.dispatch | Akka |
|
ForkJoinExecutorConfigurator .AkkaForkJoinPool | | Class | akka.dispatch.ForkJoinExecutorConfigurator | Akka |
|
ForkJoinExecutorConfigurator .AkkaForkJoinTask | INTERNAL AKKA USAGE ONLYSee Also:Serialized Form | Class | akka.dispatch.ForkJoinExecutorConfigurator | Akka |
|
Futures | | Class | akka.dispatch | Akka |
|
Futures$ | | Class | akka.dispatch | Akka |
|
japi | This class contains bridge classes between Scala and Java. | Class | akka.dispatch | Akka |
|
japi$ | This class contains bridge classes between Scala and Java. | Class | akka.dispatch | Akka |
|
japi .BooleanFunctionBridge | | Class | akka.dispatch.japi | Akka |
|
japi .CallbackBridge | | Class | akka.dispatch.japi | Akka |
|
japi .RecoverBridge | | Class | akka.dispatch.japi | Akka |
|
japi .UnitFunctionBridge | | Class | akka.dispatch.japi | Akka |
|
LatestFirstSystemMessageList | Value class supporting list operations on system messages. | Class | akka.dispatch.sysmsg | Akka |
|
LatestFirstSystemMessageList$ | | Class | akka.dispatch.sysmsg | Akka |
|
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. | Class | akka.dispatch | Akka |
|
Mailbox$ | | Class | akka.dispatch | Akka |
|
Mailboxes | | Class | akka.dispatch | Akka |
|
Mailboxes$ | | Class | akka.dispatch | Akka |
|
MailboxType | MailboxType is a factory to create MessageQueues for an optionally provided ActorContext. | Interface | akka.dispatch | Akka |
|
Mapper | Callback for the Future. | Class | akka.dispatch | Akka |
|
MessageDispatcher | | Class | akka.dispatch | Akka |
|
MessageDispatcher$ | | Class | akka.dispatch | Akka |
|
MessageDispatcherConfigurator | Base class to be used for hooking in new dispatchers into Dispatchers. | Class | akka.dispatch | Akka |
|
MessageQueue | A MessageQueue is one of the core components in forming an Akka Mailbox. | Interface | akka.dispatch | Akka |
|
MonitorableThreadFactory | | Class | akka.dispatch | Akka |
|
MonitorableThreadFactory$ | | Class | akka.dispatch | Akka |
|
MonitorableThreadFactory .AkkaForkJoinWorkerThread | | Class | akka.dispatch.MonitorableThreadFactory | Akka |
|
NodeMessageQueue | | Class | akka.dispatch | Akka |
|
NoMessage | | Class | akka.dispatch.sysmsg | Akka |
|
NoMessage$ | | Class | akka.dispatch.sysmsg | Akka |
|
NonBlockingBoundedMailbox | NonBlockingBoundedMailbox is a high-performance, multiple-producer single-consumer, bounded MailboxType, Noteworthy is that it discards overflow as DeadLetters. | Class | akka.dispatch | Akka |
|
NonBlockingBoundedMailbox$ | | Class | akka.dispatch | Akka |
|
OnComplete | Callback for when a Future is completed with either failure or a success SAM (Single Abstract Method) class | Class | akka.dispatch | Akka |
|
OnFailure | Callback for when a Future is completed with a failure SAM (Single Abstract Method) class | Class | akka.dispatch | Akka |
|
OnSuccess | Callback for when a Future is completed successfully SAM (Single Abstract Method) class | Class | akka.dispatch | Akka |
|
PinnedDispatcher | Dedicates a unique thread for each actor passed in as reference. | Class | akka.dispatch | Akka |
|
PinnedDispatcherConfigurator | Configurator for creating PinnedDispatcher. | Class | akka.dispatch | Akka |
|
PriorityGenerator | | Class | akka.dispatch | Akka |
|
PriorityGenerator$ | | Class | akka.dispatch | Akka |
|
ProducesPushTimeoutSemanticsMailbox | Used to determine mailbox factories which create BoundedMessageQueueSemantics mailboxes, and thus should be validated that the pushTimeOut is greater than 0. | Interface | akka.dispatch | Akka |
|
QueueBasedMessageQueue | A QueueBasedMessageQueue is a MessageQueue backed by a java. | Interface | akka.dispatch | Akka |
|
Recover | Callback for the Future. | Class | akka.dispatch | Akka |
|
Recreate | | Class | akka.dispatch.sysmsg | Akka |
|
Recreate$ | | Class | akka.dispatch.sysmsg | Akka |
|
RequiresMessageQueue | Trait to signal that an Actor requires a certain type of message queue semantics. | Interface | akka.dispatch | Akka |
|
Resume | | Class | akka.dispatch.sysmsg | Akka |
|
Resume$ | | Class | akka.dispatch.sysmsg | Akka |
|
SaneRejectedExecutionHandler | The RejectedExecutionHandler used by Akka, it improves on CallerRunsPolicy by throwing a RejectedExecutionException if the executor isShutdown. | Class | akka.dispatch | Akka |
|
SingleConsumerOnlyUnboundedMailbox | | Class | akka.dispatch | Akka |
|
SingleConsumerOnlyUnboundedMailbox$ | | Class | akka.dispatch | Akka |
|
Supervise | | Class | akka.dispatch.sysmsg | Akka |
|
Supervise$ | | Class | akka.dispatch.sysmsg | Akka |
|
Suspend | | Class | akka.dispatch.sysmsg | Akka |
|
Suspend$ | | Class | akka.dispatch.sysmsg | Akka |
|
SystemMessage | System messages are handled specially: they form their own queue within each actor’s mailbox. | Interface | akka.dispatch.sysmsg | Akka |
|
SystemMessageList | Helper companion object for LatestFirstSystemMessageList and EarliestFirstSystemMessageList | Class | akka.dispatch.sysmsg | Akka |
|
SystemMessageList$ | Helper companion object for LatestFirstSystemMessageList and EarliestFirstSystemMessageList | Class | akka.dispatch.sysmsg | Akka |
|
SystemMessageQueue | Dequeue all messages from system queue and return them as single-linked list. | Interface | akka.dispatch | Akka |
|
TaskInvocation | | Class | akka.dispatch | Akka |
|
TaskInvocation$ | | Class | akka.dispatch | Akka |
|
Terminate | | Class | akka.dispatch.sysmsg | Akka |
|
Terminate$ | | Class | akka.dispatch.sysmsg | Akka |
|
ThreadPoolConfig | | Class | akka.dispatch | Akka |
|
ThreadPoolConfig$ | | Class | akka.dispatch | Akka |
|
ThreadPoolConfigBuilder | A DSL to configure and create a MessageDispatcher with a ThreadPoolExecutorSee Also:Serialized Form | Class | akka.dispatch | Akka |
|
ThreadPoolConfigBuilder$ | | Class | akka.dispatch | Akka |
|
ThreadPoolExecutorConfigurator | | Class | akka.dispatch | Akka |
|
UnboundedControlAwareMailbox | UnboundedControlAwareMailbox is an unbounded MailboxType, that maintains two queues to allow messages that extend ControlMessage to be delivered with priority. | Class | akka.dispatch | Akka |
|
UnboundedControlAwareMailbox$ | | Class | akka.dispatch | Akka |
|
UnboundedControlAwareMailbox .MessageQueue | | Class | akka.dispatch.UnboundedControlAwareMailbox | Akka |
|
UnboundedControlAwareMessageQueueSemantics | | Interface | akka.dispatch | Akka |
|
UnboundedDequeBasedMailbox | UnboundedDequeBasedMailbox is an unbounded MailboxType, backed by a Deque. | Class | akka.dispatch | Akka |
|
UnboundedDequeBasedMailbox$ | | Class | akka.dispatch | Akka |
|
UnboundedDequeBasedMailbox .MessageQueue | | Class | akka.dispatch.UnboundedDequeBasedMailbox | Akka |
|
UnboundedDequeBasedMessageQueue | UnboundedDequeBasedMessageQueueSemantics adds unbounded semantics to a DequeBasedMessageQueue, i. | Interface | akka.dispatch | Akka |
|
UnboundedMailbox | UnboundedMailbox is the default unbounded MailboxType used by Akka Actors. | Class | akka.dispatch | Akka |
|
UnboundedMailbox$ | | Class | akka.dispatch | Akka |
|
UnboundedMailbox .MessageQueue | | Class | akka.dispatch.UnboundedMailbox | Akka |
|
UnboundedPriorityMailbox | UnboundedPriorityMailbox is an unbounded mailbox that allows for prioritization of its contents. | Class | akka.dispatch | Akka |
|
UnboundedPriorityMailbox$ | | Class | akka.dispatch | Akka |
|
UnboundedPriorityMailbox .MessageQueue | | Class | akka.dispatch.UnboundedPriorityMailbox | Akka |
|
UnboundedQueueBasedMessageQueue | Try to dequeue the next message from this queue, return null failing that. | Interface | akka.dispatch | Akka |
|
UnboundedStablePriorityMailbox | UnboundedStablePriorityMailbox is an unbounded mailbox that allows for prioritization of its contents. | Class | akka.dispatch | Akka |
|
UnboundedStablePriorityMailbox$ | | Class | akka.dispatch | Akka |
|
UnboundedStablePriorityMailbox .MessageQueue | | Class | akka.dispatch.UnboundedStablePriorityMailbox | Akka |
|
Unwatch | | Class | akka.dispatch.sysmsg | Akka |
|
Unwatch$ | | Class | akka.dispatch.sysmsg | Akka |
|
Watch | | Class | akka.dispatch.sysmsg | Akka |
|
Watch$ | | Class | akka.dispatch.sysmsg | Akka |