How to run a Task on a custom TaskScheduler using await?

by

I think what you really want is to do a Task.Run, but with a custom scheduler. StartNew doesn’t work intuitively with asynchronous methods; Stephen Toub has a great blog post about the differences between Task.Run and TaskFactory.StartNew.

So, to create your own custom Run, you can do something like this:

private static readonly TaskFactory myTaskFactory = new TaskFactory(
    CancellationToken.None, TaskCreationOptions.DenyChildAttach,
    TaskContinuationOptions.None, new MyTaskScheduler());
private static Task RunOnMyScheduler(Func<Task> func)
{
  return myTaskFactory.StartNew(func).Unwrap();
}
private static Task<T> RunOnMyScheduler<T>(Func<Task<T>> func)
{
  return myTaskFactory.StartNew(func).Unwrap();
}
private static Task RunOnMyScheduler(Action func)
{
  return myTaskFactory.StartNew(func);
}
private static Task<T> RunOnMyScheduler<T>(Func<T> func)
{
  return myTaskFactory.StartNew(func);
}

Then you can execute synchronous or asynchronous methods on your custom scheduler.

More Related Contents:

  1. How and when to use ‘async’ and ‘await’
  2. What is the purpose of “return await” in C#?
  3. If async-await doesn’t create any additional threads, then how does it make applications responsive?
  4. Awaiting multiple Tasks with different results
  5. How do yield and await implement flow of control in .NET?
  6. Fire and forget async method in asp.net mvc
  7. Why can’t I use the ‘await’ operator within the body of a lock statement?
  8. Why should I prefer single ‘await Task.WhenAll’ over multiple awaits?
  9. Synchronously waiting for an async operation, and why does Wait() freeze the program here
  10. Enforce an async method to be called once
  11. Is there anything like asynchronous BlockingCollection?
  12. Cancelling a pending task synchronously on the UI thread
  13. What is the use for Task.FromResult in C#
  14. Why use Async/await all the way down
  15. Await operator can only be used within an Async method [duplicate]
  16. Can the Oracle managed driver use async/await properly?
  17. Different forms of the WCF service contract interface
  18. Async await vs GetAwaiter().GetResult() and callback
  19. EF Data Context – Async/Await & Multithreading
  20. How does async works in C#?
  21. Should I worry about “This async method lacks ‘await’ operators and will run synchronously” warning
  22. Task.Factory.StartNew with async lambda and Task.WaitAll
  23. What is the correct way to cancel an async operation that doesn’t accept a CancellationToken?
  24. Async thread body loop, It just works, but how?
  25. Non-Generic TaskCompletionSource or alternative
  26. How do I get a return value from Task.WaitAll() in a console app?
  27. Async and Await with For Loop [duplicate]
  28. When is the best place to use Task.Result instead of awaiting Task
  29. Timeout pattern on task-based asynchronous method in C#
  30. Wrapping ManualResetEvent as awaitable task

Leave a Comment