Class ActorTaskScheduler

TBD

Inheritance
object
TaskScheduler
ActorTaskScheduler
Inherited Members
Namespace: Akka.Dispatch
Assembly: Akka.dll
Syntax
public class ActorTaskScheduler : TaskScheduler

Constructors

| Edit this page View Source

ActorTaskScheduler(ActorCell)

Creates a new ActorTaskScheduler bound to the given ActorCell.

Exposed as protected internal so external libraries (notably Phobos, the Akka.NET observability plugin) can subclass ActorTaskScheduler and override OnBeforeTaskStarted() / OnAfterTaskCompleted() to observe async message handler lifetimes without reflection or runtime codegen. The two virtual hooks have always been protected, so widening the constructor to match finishes an extension point that was already half-exposed. The internal portion preserves the existing new ActorTaskScheduler(this) call site inside ActorCell without requiring a derived type.

Declaration
protected ActorTaskScheduler(ActorCell actorCell)
Parameters
Type Name Description
ActorCell actorCell

The cell this scheduler is bound to.

Properties

| Edit this page View Source

CurrentMessage

TBD

Declaration
public object CurrentMessage { get; }
Property Value
Type Description
object
| Edit this page View Source

MaximumConcurrencyLevel

TBD

Declaration
public override int MaximumConcurrencyLevel { get; }
Property Value
Type Description
int
Overrides

Methods

| Edit this page View Source

GetScheduledTasks()

TBD

Declaration
protected override IEnumerable<Task> GetScheduledTasks()
Returns
Type Description
IEnumerable<Task>

TBD
Overrides
| Edit this page View Source

OnAfterTaskCompleted()

Called in completed scheduled task continuation

Declaration
protected virtual void OnAfterTaskCompleted()
| Edit this page View Source

OnBeforeTaskStarted()

Called when async task is scheduled, before Task.StartNew call

Declaration
protected virtual void OnBeforeTaskStarted()
| Edit this page View Source

QueueTask(Task)

TBD

Declaration
protected override void QueueTask(Task task)
Parameters
Type Name Description
Task task

TBD
Overrides
| Edit this page View Source

RunTask(Action)

TBD

Declaration
public static void RunTask(Action action)
Parameters
Type Name Description
Action action

TBD
| Edit this page View Source

RunTask(Func<Task>)

TBD

Declaration
public static void RunTask(Func<Task> asyncAction)
Parameters
Type Name Description
Func<Task> asyncAction

TBD
Exceptions
Type Condition
InvalidOperationException

This exception is thrown if this method is called outside an actor context.
| Edit this page View Source

TryExecuteTaskInline(Task, bool)

TBD

Declaration
protected override bool TryExecuteTaskInline(Task task, bool taskWasPreviouslyQueued)
Parameters
Type Name Description
Task task

TBD
bool taskWasPreviouslyQueued

TBD
Returns
Type Description
bool

TBD
Overrides

Extension Methods