Class 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.

Inheritance
Object
MessageDispatcher
Dispatcher
CurrentSynchronizationContextDispatcher
PinnedDispatcher
Inherited Members
Namespace: Akka.Dispatch
Assembly: Akka.dll
Syntax
public class Dispatcher : MessageDispatcher

Constructors

| Improve this Doc View Source

Dispatcher(MessageDispatcherConfigurator, String, Int32, Nullable<Int64>, ExecutorServiceFactory, TimeSpan)

Used to create a default Dispatcher

Declaration
public Dispatcher(MessageDispatcherConfigurator configurator, string id, int throughput, long? throughputDeadlineTime, ExecutorServiceFactory executorServiceFactory, TimeSpan shutdownTimeout)
Parameters
Type Name Description
MessageDispatcherConfigurator configurator

The configurator used.
String id

The id of this dispatcher.
Int32 throughput

The throughput of this dispatcher.
Nullable<Int64> throughputDeadlineTime

The deadline for completing N (where N = throughput) operations on the mailbox..
Akka.Dispatch.ExecutorServiceFactory executorServiceFactory

The factory for producing the executor who will do the work.
TimeSpan shutdownTimeout

The graceful stop timeout period.

Methods

| Improve this Doc View Source

ExecuteTask(IRunnable)

Schedules the IRunnable to be executed.

Declaration
protected override void ExecuteTask(IRunnable run)
Parameters
Type Name Description
IRunnable run

The asynchronous task we're going to run
Overrides

Extension Methods