为何被await的异步方法会在完成前返回调用线程？

核心问题根源 #

你碰到的“同一上下文启动第二个操作”错误，本质是用Wait()同步阻塞异步代码导致的上下文混乱，再加上EF Core的DbContext天生线程不安全：

• FailedOrderTask.OnRun里的Task.Run(() => ...).Wait()强行将异步方法同步化，打乱了async/await的线程调度逻辑
• 当GetFailedOrders执行到await ToListAsync()时，线程会被释放，主线程会继续执行基类Run方法的_logRecorder.LogProcessRunDate——如果日志操作间接用到了同一个DbContext，就会和未完成的仓储查询操作形成并发访问
• 其他任务看似正常，只是因为它们的异步操作没有长期持有DbContext，或者不涉及共享的线程不安全资源，属于侥幸运行

修复步骤 #

1. 重构基类为异步范式

把基类的执行逻辑改为异步，从根源避免同步阻塞：

public abstract class ScheduledTaskBase : ITask
{
    private readonly ILogRecorder _logRecorder;
    protected ScheduledTaskBase(ILogRecorder logRecorder)
    {
        _logRecorder = logRecorder;
    }

    protected IConfigurationRoot Configuration { get; private set; }

    // 替换同步Run为异步RunAsync
    public async Task RunAsync()
    {
        await OnRunAsync();
        _logRecorder.LogProcessRunDate(TaskType);
    }
    
    protected abstract ScheduledTask TaskType { get; }
    // 抽象方法改为异步
    protected abstract Task OnRunAsync();
}

2. 修正子类的异步执行逻辑

去掉Task.Run().Wait()的错误写法，直接异步调用业务方法：

public class FailedOrderTask : ScheduledTaskBase
{
    protected override ScheduledTask TaskType => ScheduledTask.FailedOrderTask;

    private readonly IService _service;
    public FailedOrderTask(IService service, ILogRecorder logRecorder) : base(logRecorder)
    {
        _service = service;
    }

    protected override async Task OnRunAsync()
    {
        // 直接异步调用，无需额外线程包装
        await _service.ProcessFailedOrders();
    }
}

3. 确保DbContext的生命周期安全

如果你的DbContext是单例或者生命周期过长，必须调整为：

• 依赖注入时将DbContext注册为Scoped（控制台程序需手动创建作用域）
• 禁止在单例服务中持有DbContext实例，确保每个异步操作都使用独立的上下文

关于其他任务的“正常运行” #

那些任务的Task.Run(...).Wait()能正常执行，只是巧合：它们的异步方法要么没有在await后继续使用DbContext，要么操作不涉及共享线程不安全资源。但这种同步阻塞异步代码的写法本身是错误的，会埋下线程安全隐患，建议统一重构为异步范式。

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