如何在自定义TaskScheduler上调度并完成async Task异步任务？

这个问题确实戳中了异步任务调度里的一个容易踩坑的点——普通的Task启动方法要么会在await后跳走，要么会引入async void的风险。别担心，这里有几个靠谱的方案可以实现你的需求：

方案1：用Task.Factory.StartNew + Unwrap（最直接的解决方式） #

你之前提到Task.Factory.StartNew会在第一个await后认为任务完成，其实是因为直接传入async方法时，StartNew会返回Task<Task>：外层Task在async方法遇到第一个await时就会标记为完成，而真正的异步逻辑藏在内部的Task里。解决这个问题的核心就是用Unwrap()把嵌套的任务展开，同时配合正确的参数和配置：

// 实例化你的自定义调度器
var customScheduler = new YourCustomTaskScheduler();

// 启动异步任务并确保全程在自定义调度器执行
Task fullAsyncTask = Task.Factory.StartNew(
    async () => await YourAsyncTaskMethod().ConfigureAwait(true),
    CancellationToken.None,
    TaskCreationOptions.DenyChildAttach,
    customScheduler)
    .Unwrap();

这里的几个关键细节：

• ConfigureAwait(true)：强制每个await之后回到当前上下文（也就是自定义调度器），保证后续代码不会跳去默认调度器。
• TaskCreationOptions.DenyChildAttach：防止子任务意外附加到外层任务，避免调度逻辑混乱。
• Unwrap()：把Task<Task>转换成一个代表整个异步流程的Task，这样你可以正确等待整个任务完成。

方案2：封装自定义扩展方法（让调用更简洁） #

如果觉得每次写StartNew+Unwrap太繁琐，可以封装一个扩展方法，把逻辑封装起来：

public static class TaskSchedulerExtensions
{
    // 无返回值的异步任务
    public static Task StartAsync(this TaskScheduler scheduler, Func<Task> asyncAction, CancellationToken token = default)
    {
        return Task.Factory.StartNew(asyncAction, token, TaskCreationOptions.DenyChildAttach, scheduler).Unwrap();
    }

    // 有返回值的异步任务
    public static Task<TResult> StartAsync<TResult>(this TaskScheduler scheduler, Func<Task<TResult>> asyncFunc, CancellationToken token = default)
    {
        return Task.Factory.StartNew(asyncFunc, token, TaskCreationOptions.DenyChildAttach, scheduler).Unwrap();
    }
}

调用的时候就非常清爽了：

var customScheduler = new YourCustomTaskScheduler();
var asyncTask = customScheduler.StartAsync(() => YourAsyncTaskMethod());

方案3：用TaskCompletionSource手动控制（底层灵活方案） #

如果你需要更精细的控制逻辑，可以用TaskCompletionSource手动管理任务的生命周期：

public static Task RunOnCustomScheduler(Func<Task> asyncAction, TaskScheduler scheduler)
{
    var tcs = new TaskCompletionSource<object>();
    
    // 在自定义调度器上启动包装任务
    Task.Factory.StartNew(async () =>
    {
        try
        {
            await asyncAction().ConfigureAwait(true);
            tcs.SetResult(null);
        }
        catch (Exception ex)
        {
            tcs.SetException(ex);
        }
    }, CancellationToken.None, TaskCreationOptions.DenyChildAttach, scheduler);
    
    return tcs.Task;
}

这个方法的本质是把你的异步逻辑包装在一个由自定义调度器启动的任务里，通过TaskCompletionSource传递异步操作的结果和异常，完全掌控调度流程。

必看注意事项 #

• 全程坚持ConfigureAwait(true)：只要有一个await没加这个配置，后续代码就可能跳转到默认调度器，前功尽弃。
• 绝对避免async void：所有异步逻辑都要封装成async Task或async Task<T>，这也是你已经注意到的风险，一定要严格遵守。

内容的提问来源于stack exchange，提问作者SpiritBob