PostSharp 2023.0 / / Post­Sharp Documentation / API Reference / Post­Sharp.​Patterns.​Threading Namespace / Actor­Dispatcher Class

ActorDispatcher Class

A dispatcher compatible with the ActorThreadingModel threading model, with a message queue based on a ConcurrentQueue The queue itself is processed from the ThreadPool.
Inheritance Hierarchy

Namespace:  PostSharp.Patterns.Threading
Assembly:  PostSharp.Patterns.Threading (in PostSharp.Patterns.Threading.dll) Version: 2023.0.3.0 (2023.0.3.0)
public class ActorDispatcher : IActorDispatcher, 

The ActorDispatcher type exposes the following members.

Public methodActorDispatcher
Initializes a new ActorDispatcher.
Public propertyIsQueueEmpty
Determines whether there are work items in the queue.
Public methodBeginInvoke
Queues an action for asynchronous execution.
Public methodCheckAccess
Determines whether the current thread has access to the current dispatcher.
Public methodInvoke
Executes an action synchronously.
Protected methodMustYield
Determines whether the ProcessQueue() method should interrupt the processing of the message queue before the queue is empty.
Protected methodOnQueueEmpty
Method invoked when the queue becomes empty. The default implementation does not do anything.
Protected methodProcessQueue
Processes the message queue synchronously.
Protected methodScheduleProcessQueue
Schedules the execution of the ProcessQueue(), typically on a worker thread or in the ThreadPool. The default implementation uses the ThreadPool on platforms that have a thread pool, otherwise it schedules a new Task.

This implementation will append every action (as a result of the BeginInvoke(SendOrPostCallback, Object) method) into a ConcurrentQueue. If will then create a work item to process the ConcurrentQueue and schedule the work item to the ThreadPool. The same work item will keep running unless the message queue is empty, then will terminate.

You can use a different scheduling mechanism instead of the ThreadPool by deriving the class and overriding the ScheduleProcessQueue() method.

Note that the Invoke(SendOrPostCallback, Object) method of the IDispatcher interface is not supported, because the ActorThreadingModel does not support synchronous calls.

See Also