Enhancement: create ActorTaskScheduler overload that schedules Task to dispatcher without blocking current actor

Version: 1.4.3 and later

An advanced feature - right now we support the ability to schedule a `Task` onto the current actor's dispatcher using the `ActorTaskScheduler`:

https://github.com/akkadotnet/akka.net/blob/03341fc2e2157620abf5986473faa5f235723ca4/src/core/Akka/Dispatch/ActorTaskScheduler.cs#L130-L164

One of the side effects of this method is that it blocks the current actor in order to run that `Task`.

I think it'd be worthwhile to add an overload that allows a task to be scheduled onto the current dispatcher, _without_ impacting the current actor's ability to process its mailbox. That could make for some interesting scenarios in areas like IOT, where users often need to run actors on pinned or dedicated thread dispatchers.


	public static void RunTask(Func<Task> asyncAction)
	{
	var context = ActorCell.Current;

	if (context == null)
	throw new InvalidOperationException("RunTask must be called from an actor context.");

	var dispatcher = context.Dispatcher;

	//suspend the mailbox
	dispatcher.Suspend(context);

	ActorTaskScheduler actorScheduler = context.TaskScheduler;
	actorScheduler.CurrentMessage = context.CurrentMessage;

	Task<Task>.Factory.StartNew(asyncAction, CancellationToken.None, TaskCreationOptions.None, actorScheduler)
	.Unwrap()
	.ContinueWith(parent =>
	{
	Exception exception = GetTaskException(parent);

	if (exception == null)
	{
	dispatcher.Resume(context);

	context.CheckReceiveTimeout();
	}
	else
	{
	context.Self.AsInstanceOf<IInternalActorRef>().SendSystemMessage(new ActorTaskSchedulerMessage(exception, actorScheduler.CurrentMessage));
	}
	//clear the current message field of the scheduler
	actorScheduler.CurrentMessage = null;
	}, actorScheduler);
	}

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Enhancement: create ActorTaskScheduler overload that schedules Task to dispatcher without blocking current actor #4363

Metadata

Assignees

Labels

Type

Projects

Milestone

Relationships

Development