EF Core多DbContext多线程下SQL事务：部分回滚部分提交实现

问题场景 #

我有10个需要并行运行的方法，每个方法都会创建独立的DbContext执行大量数据库更新操作——由于单DbContext会影响大更新的效率，所以必须用独立实例。现在需要实现：

• 若Method1~Method9中任意一个执行失败，这9个方法的所有数据库变更都不能保存
• Method10的变更不受前面9个方法的结果影响，无论成功失败都要正常保存

试过TransactionScope但发现如果不提交事务，Method10的变更也会被回滚，不知道怎么处理。

原代码如下：

var task1 = Task.Run(Method1);
var task2 = Task.Run(Method2);
var task3 = Task.Run(Method3);
var task10 = Task.Run(Method10);

Task.WaitAll(task1, task2, task3, task10);

void Method1()
{
    using (MyContext context = new MyContext())
    {
        // 大量更新操作
    }
}

void Method2()
{
    using (MyContext context = new MyContext())
    {
        // 大量更新操作
    }
}

void Method3()
{
    using (MyContext context = new MyContext())
    {
        // 大量更新操作
    }
}

void Method10()
{
    using (MyContext context = new MyContext())
    {
        // 大量更新操作
    }
}

class MyContext : DbContext
{

}

解决方案 #

核心思路是把Method1~Method9纳入同一个共享事务，Method10完全独立执行自己的事务，具体实现如下：

1. 调整事务范围与任务执行逻辑 #

将Method1~Method9放在同一个TransactionScope中执行，利用事务的传播特性让所有独立DbContext加入到同一事务；Method10单独启动，不加入这个事务范围。

2. 修改后的代码示例 #

// 先启动Method10的任务，完全独立执行
var task10 = Task.Run(Method10);

// 包装Method1~Method9的任务，让它们在共享事务中执行
var groupTasks = new List<Task>
{
    Task.Run(MethodInTransaction),
    Task.Run(Method2InTransaction),
    Task.Run(Method3InTransaction),
    // ... 依次添加Method4~Method9的任务
};

try
{
    // 启用异步事务流动，确保子线程能共享事务
    using (var scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled))
    {
        // 等待所有Method1~Method9的任务完成
        await Task.WhenAll(groupTasks);
        // 所有任务都成功才提交事务
        scope.Complete();
    }
}
catch
{
    // 任何一个任务失败，事务自动回滚，无需额外操作
}

// 等待Method10完成，它的事务不受前面逻辑影响
await task10;

// Method1~Method9的修改版本：无需自己管理事务，自动加入外部Scope
void MethodInTransaction()
{
    using (var context = new MyContext())
    {
        // 执行大量更新操作
        context.SaveChanges(); // 仅将变更写入事务，最终由外部Scope决定提交/回滚
    }
}

// Method10保持独立，自行管理事务
void Method10()
{
    using (var context = new MyContext())
    {
        // 执行大量更新操作
        context.SaveChanges(); // 直接提交到数据库，不受其他事务影响
    }
}

class MyContext : DbContext
{
    // 确保DbContext配置适配数据库（比如SQL Server默认支持事务传播）
}

关键细节说明 #

• TransactionScopeAsyncFlowOption.Enabled：必须添加这个参数，否则异步任务无法共享事务上下文。
• 事务自动回滚：只要Method1~Method9中有一个任务抛出异常，Task.WhenAll会触发捕获逻辑，TransactionScope会自动回滚所有已执行的变更，无需手动处理。
• Method10的独立性：它完全不在共享事务范围内，DbContext会创建自己的独立事务，SaveChanges直接提交，不受前面9个方法的失败影响。
• 数据库支持：如果所有操作都在同一个数据库，TransactionScope会自动使用本地事务，无需开启MSDTC；跨库的话才需要配置分布式事务。

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