EF Core技术选型：复用DbContext还是为每个方法创建新实例？

核心结论 #

绝对不能在Parallel.ForEach的并行任务之间共享同一个DbContext实例，正确的做法是：为每个并行任务（即单条记录的完整处理流程）创建一个独立的DbContext，并将其传入该任务内的所有方法，而非每个方法单独创建DbContext。

为什么不能共享DbContext #

Entity Framework Core的DbContext设计为单线程、短生命周期的对象，它内部维护了实体的变更追踪、缓存等状态，这些状态完全不支持并发访问。如果多个并行任务共享同一个DbContext，会导致：

• 上下文状态混乱，出现不可预测的实体变更
• 数据读写不一致
• 抛出InvalidOperationException等并发异常

当前实现的额外问题 #

你当前使用Parallel.ForEach结合异步委托的写法存在隐患：Parallel.ForEach不支持异步委托，它会直接返回而不会等待内部的异步操作完成，导致任务处理逻辑可能还没执行完，程序就继续往下走了。建议替换为.NET 6+支持的Parallel.ForEachAsync，或者用Task.WhenAll配合普通foreach。

正确实现示例 #

1. 重构并行处理逻辑（每个任务一个DbContext）

// 获取待处理任务列表
List<Vaux00JobController> tasksToExecute = GetTasks();

// 使用Parallel.ForEachAsync处理异步并行任务（.NET 6+）
await Parallel.ForEachAsync(tasksToExecute, async (job, cancellationToken) =>
{
    // 为当前任务创建独立的DbContext，用using自动释放
    using var db = _contextFactory.CreateDbContext();
    decimal logId = 0;

    try
    {
        // 将DbContext传入各个业务方法
        logId = await TransactionStarted(db, job, cancellationToken);

        Tuple<string, string> attributes = await GetAttributesFromTaskId(db, job.Id, cancellationToken);
        string apiParams = attributes.Item1;
        string apiUrl = attributes.Item2;

        bool apiResult = await CallApi(apiParams, apiUrl, cancellationToken);
        if (apiResult)
        {
            await TransactionCompleted(db, logId, job.Id, cancellationToken);
        }
        else
        {
            await TransactionFailed(db, logId, job.Id, cancellationToken);
        }

        // 统一提交当前任务的所有数据库变更
        await db.SaveChangesAsync(cancellationToken);
    }
    catch (Exception ex)
    {
        // 异常处理：比如记录日志、回滚操作等
        // 若使用了事务，可在此处调用db.Database.RollbackAsync()
    }
});

2. 重构业务方法（接收DbContext参数）

// 示例：修改TransactionStarted方法，接收DbContext
private async Task<decimal> TransactionStarted(AppDbContext db, Vaux00JobController job, CancellationToken cancellationToken)
{
    // 使用传入的DbContext进行数据库操作
    var targetJob = await db.Vaux00JobControllers
        .FirstOrDefaultAsync(j => j.Id == job.Id, cancellationToken);
    
    if (targetJob != null)
    {
        targetJob.Status = "TransactionStarted";
        // 此处不立即提交，留到任务最后统一SaveChanges
    }

    var transactionLog = new TransactionLog
    {
        JobId = job.Id,
        StartTime = DateTime.UtcNow,
        Status = "Started"
    };
    db.TransactionLogs.Add(transactionLog);
    
    // 如果需要立即获取logId，可在此处调用一次SaveChangesAsync
    await db.SaveChangesAsync(cancellationToken);
    return transactionLog.Id;
}

// 其他业务方法（GetAttributesFromTaskId、TransactionCompleted等）同理，都接收DbContext参数

方案对比 #

额外注意事项 #

• 后台服务中，DbContext的生命周期必须严格控制为短生命周期，用using包裹确保及时释放资源。
• 所有异步方法都要传入CancellationToken，方便在服务停止时优雅终止任务。
• 若需要跨多个方法的事务，可在任务开始时调用db.Database.BeginTransactionAsync()，最后统一提交或异常时回滚。

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