Akka.Dispatch Namespace |
Class | Description | |
---|---|---|
ActionRunnable | ||
ActionWithStateRunnable | ||
ActorTaskScheduler |
TBD
| |
BoundedDequeBasedMailbox |
BoundedDequeBasedMailbox is an bounded MailboxType backed by a double-ended queue. Used for stashing.
| |
BoundedMailbox |
The default bounded mailbox implementation
| |
CurrentSynchronizationContextDispatcher |
Behaves like a PinnedDispatcher and always executes using CurrentSynchronizationContextExecutorServiceFactory | |
DefaultDispatcherPrerequisites |
The default set of contextual data needed for MessageDispatcherConfigurators
| |
Dispatcher |
The event-based Dispatcher binds a set of actors to a thread pool backed up
by a thread-safe queue.
The preferred way of creating dispatchers is to define them in configuration and use the
Lookup(String) method.
| |
DispatcherConfigurator |
The cached MessageDispatcher factory that gets looked up via configuration
inside Dispatchers | |
Dispatchers |
The registry of all MessageDispatcher instances available to this ActorSystem.
| |
ExecutorService |
Used by the Dispatcher to execute asynchronous invocations
| |
ExecutorServiceConfigurator |
INTERNAL API - used to configure the executor used by the Dispatcher | |
ExecutorServiceFactory |
INTERNAL API
Used to produce ExecutorServiceFactory instances for use inside Dispatchers
| |
FutureActor |
Class FutureActor.
| |
Mailbox |
Mailbox base class
| |
Mailboxes |
Contains the directory of all MailboxTypes registered and configured with a given ActorSystem.
| |
MailboxType |
A factory to create IMessageQueues for an optionally provided IActorContext.
| |
MessageDispatcher |
Class responsible for pushing messages from an actor's mailbox into its
receive methods. Comes in many different flavors.
| |
MessageDispatcherConfigurator |
Base class used for hooking new MessageDispatcher types into Dispatchers | |
PinnedDispatcher |
Dedicates a unique thread for each actor passed in as reference. Served through its IMessageQueue.
The preferred way of creating dispatcher is to define them in configuration and then use the Lookup(String)
method.
| |
RejectedExecutionException |
Thrown when a ExecutorService implementation rejects
| |
ThreadPoolConfig |
Used inside Akka.Remote for constructing the low-level Helios threadpool, but inside
vanilla Akka it's also used for constructing custom fixed-size-threadpool dispatchers.
| |
UnboundedDequeBasedMailbox |
UnboundedDequeBasedMailbox is an unbounded MailboxType backed by a double-ended queue. Used for stashing.
| |
UnboundedMailbox |
UnboundedMailbox is the default MailboxType used by Akka.NET Actors
| |
UnboundedPriorityMailbox |
Priority mailbox base class; unbounded mailbox that allows for prioritization of its contents.
Extend this class and implement the PriorityGenerator(Object) method with your own prioritization.
The value returned by the PriorityGenerator(Object) method will be used to order the message in the mailbox.
Lower values will be delivered first. Messages ordered by the same number will remain in delivery order.
|
Interface | Description | |
---|---|---|
IBlockingMessageQueueSemantics |
Semantics for message queues that are blocking
| |
IBoundedDequeBasedMessageQueueSemantics |
Semantics for message queues that are Double-Ended and bounded
| |
IBoundedMessageQueueSemantics |
Semantics for message queues that have a bounded size
| |
IDequeBasedMessageQueueSemantics |
Semantics for message queues that are Double-Ended.
| |
IDispatcherPrerequisites |
Contextual information that's useful for dispatchers
| |
IMultipleConsumerSemantics |
Semantics for message queues that support multiple consumers
| |
IProducesMessageQueueTQueue |
Compliment to IRequiresMessageQueueT | |
IRequiresMessageQueueT |
Used to help give hints to the ActorSystem as to what types of IMessageQueue this
actor requires. Used mostly for system actors.
| |
IRunnable |
An asynchronous operation will be executed by a MessageDispatcher.
| |
ISemantics |
TBD
| |
IUnboundedDequeBasedMessageQueueSemantics |
Semantics for message queues that are Double-Ended and unbounded
| |
IUnboundedMessageQueueSemantics |
Semantics for message queues that have an unbounded size
|