Search Java Classes and Packages
#Akka.dispatch Classes and Interfaces - 161 results found.
| 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 | |