如何在多线程场景下使用工作单元（Unit of Work）模式？

EF Core的DbContext本身是非线程安全的，同一个实例不能被多个线程/异步操作同时调用——你的三个并行任务共享了同一个工作单元（以及其中的DbContext实例），这就是触发different threads concurrently using the same instance of DbContext异常的核心原因。

工作单元模式完全可以在多线程/并行异步场景下使用，但核心要求是每个并行操作必须拥有独立的工作单元（即独立的DbContext实例），绝对不能共享同一个实例。

具体实现方案（以ASP.NET Core为例） #

如果你的应用基于依赖注入（DI）开发，可以通过IServiceScopeFactory为每个并行任务创建独立的服务作用域，确保每个任务拿到的工作单元、仓储、服务都绑定独立的DbContext实例：

// 注入IServiceScopeFactory
private readonly IServiceScopeFactory _scopeFactory;

public YourService(IServiceScopeFactory scopeFactory)
{
    _scopeFactory = scopeFactory;
}

public async Task<YourResultType> YourMethodAsync(YourDataType data)
{
    // 为每个并行任务创建独立作用域，隔离DbContext实例
    var insertYekkaTask = Task.Run(async () =>
    {
        using var scope = _scopeFactory.CreateScope();
        var unitOfWork = scope.ServiceProvider.GetRequiredService<IUnitOfWork>();
        return await unitOfWork.YekkaRepository.InsertAsync(new(data.AdvertID, data.MatchID));
    });

    var getMatchTask = Task.Run(async () =>
    {
        using var scope = _scopeFactory.CreateScope();
        var matchService = scope.ServiceProvider.GetRequiredService<IMatchService>();
        return await matchService.GetAsync(data.MatchID);
    });

    var getAdvertTask = Task.Run(async () =>
    {
        using var scope = _scopeFactory.CreateScope();
        var advertisementService = scope.ServiceProvider.GetRequiredService<IAdvertisementService>();
        return await advertisementService.GetAsync(data.AdvertID);
    });

    await Task.WhenAll(insertYekkaTask, getMatchTask, getAdvertTask);

    var yekkaId = insertYekkaTask.Result;
    var match = getMatchTask.Result;
    var advertisement = getAdvertTask.Result;

    // 后续业务逻辑处理
}

额外注意事项 #

• 确保你的服务（matchService、advertisementService）和工作单元的生命周期配置为Scoped，这样每个作用域内会生成全新的服务实例，绑定独立的DbContext。
• 不要盲目并行：如果三个操作存在数据依赖（比如插入操作会影响查询结果），并行可能导致数据不一致，这种情况下应该改为串行执行。
• 非DI场景下：如果不使用依赖注入，需要在每个并行任务中手动创建新的DbContext和工作单元实例，使用完成后及时释放资源。

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