如何在事务中异步正确使用DbContext？

我有一个可拆分为多个短操作的长时间运行任务，希望能异步调用DbContext，但运行时出现线程安全报错。以下是代码实现及错误信息：

代码实现 #

数据服务类 #

public class MyDataService : IMyDataService
{
    private readonly IMyRepository _repository;
    private readonly ITransactionScope _txScope;

    public MyDataService(IMyRepository repository, ITransactionScope txScope)
    {
        _repository = repository;
        _txScope = txScope;
    }

    public async Task<Result> CreateOrAppendAsync(SomeObject[] someObjects)
    {
        return await _txScope.DoInTransactionAsync(
            _principal.GetName(),
            "create-or-append",
            null,
            async () => await _repository.CreateOrAppendAsync(someObjects));
    }
}

仓储类 #

public class MyRepository : IRepository
{
    private readonly InternalDbContext _dbContext;

    public Repository(InternalDbContext dbContext)
    {
        _dbContext = dbContext;
    }

    public async Task<Result> CreateOrAppendAsync(SomeObject[] someObjects)
    {
        var tasks = new List<Task<PartOfResult>>();
        foreach (var batch in someObjects.Split(10))
        {
            tasks.Add(Task.Run(() =>
            {
                // do something with _dbContext to get result
            }));
        }
        var results = await Task.WhenAll(tasks.ToArray());
        return results.Combine();
    }
}

报错信息 #

A second operation was started on this context instance before a previous operation completed. This is usually caused by different threads concurrently using the same instance of DbContext.

我之前尝试复制DbContext，但由于所有操作都在同一事务中，这种方式不可行。PostgreSQL数据库支持多调用，.NET也有便捷的并行处理语法，请问如何结合EF Core正确实现该需求？

EF Core的DbContext实例不是线程安全的，不能在多个并行任务中共享使用。要在同一事务下并行处理数据，需要为每个任务创建独立的DbContext实例，并将它们绑定到同一个事务中。

核心步骤 #

1. 使用IDbContextFactory创建独立的DbContext实例（EF Core推荐的多实例创建方式）
2. 从原有DbContext获取当前事务对象，将新创建的DbContext绑定到该事务
3. 每个并行任务使用专属的DbContext处理批数据
4. 外层事务统一管理提交/回滚

修改后的仓储类代码 #

public class MyRepository : IRepository
{
    private readonly IDbContextFactory<InternalDbContext> _dbContextFactory;
    private readonly InternalDbContext _originalDbContext;

    // 注入DbContext工厂和原DbContext（用于获取当前事务）
    public MyRepository(IDbContextFactory<InternalDbContext> dbContextFactory, InternalDbContext originalDbContext)
    {
        _dbContextFactory = dbContextFactory;
        _originalDbContext = originalDbContext;
    }

    public async Task<Result> CreateOrAppendAsync(SomeObject[] someObjects)
    {
        // 确保当前处于事务范围内
        var currentTransaction = _originalDbContext.Database.CurrentTransaction;
        if (currentTransaction == null)
        {
            throw new InvalidOperationException("操作必须在事务上下文内执行");
        }

        var tasks = new List<Task<PartOfResult>>();
        foreach (var batch in someObjects.Split(10))
        {
            // 为每个批次创建独立的处理任务
            tasks.Add(ProcessBatchAsync(batch, currentTransaction));
        }

        var results = await Task.WhenAll(tasks);
        return results.Combine();
    }

    private async Task<PartOfResult> ProcessBatchAsync(SomeObject[] batch, IDbContextTransaction currentTransaction)
    {
        // 创建新的DbContext实例
        using var dbContext = _dbContextFactory.CreateDbContext();
        // 将新DbContext绑定到现有事务
        await dbContext.Database.UseTransactionAsync(currentTransaction.GetDbTransaction());

        // 处理当前批次的业务逻辑
        var partResult = new PartOfResult();
        foreach (var item in batch)
        {
            // 示例：添加/更新实体
            dbContext.SomeEntities.Add(item);
            // 自定义业务逻辑...
        }
        await dbContext.SaveChangesAsync();

        return partResult;
    }
}

额外注意事项 #

• 确保外层的ITransactionScope支持异步事务流（若使用官方TransactionScope，需指定TransactionScopeAsyncFlowOption.Enabled）
• 不需要在子任务中手动提交事务，外层事务会统一处理所有绑定DbContext的提交/回滚
• PostgreSQL本身支持多线程事务操作，此方案完全适配PostgreSQL环境

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