在Task.Run中并行执行EF Core 6 CRUD时遇实体跟踪冲突错误

问题场景 #

使用EF Core 6结合仓储模式与工作单元模式，依赖注入配置如下：

services.AddDbContext<ApplicationDBContext>(options =>
    options.UseSqlServer(configuration.GetConnectionString("DefaultConnection"), 
    providers => providers.EnableRetryOnFailure(3, TimeSpan.FromSeconds(10), null))
);

services.AddScoped<ISupplierRepository, SupplierRepository>();

services.AddScoped<IUnitOfWork, UnitOfWork>();

通过工厂模式初始化包含数据库CRUD逻辑的服务类：

using (var scope = _serviceProvider.CreateScope())
{
    _messageFactory = scope.ServiceProvider.GetService<IAvroMessageFactory>();
    messageHandler = _messageFactory.GetMessageHandler(serviceName);

    if (await messageHandler.AddMessage(messageValue)) // crud logic is written here
    {
    }
}

将AddMessage调用放入Task.Run并行执行时，出现错误：

The instance of entity type cannot be tracked because another instance of this type with the same key is already being tracked

解决办法 #

1. 为每个并行任务创建独立的DI作用域 #

核心原因是原代码中多个并行任务共享同一个DI作用域，导致DbContext实例被复用，同一实体被多个任务同时跟踪。解决方式是让每个并行任务拥有独立的作用域和DbContext：

// 并行执行的代码示例
await Task.Run(async () =>
{
    using (var scope = _serviceProvider.CreateScope())
    {
        var messageFactory = scope.ServiceProvider.GetRequiredService<IAvroMessageFactory>();
        var messageHandler = messageFactory.GetMessageHandler(serviceName);
        await messageHandler.AddMessage(messageValue);
    }
});

每个Task.Run内部创建独立的作用域，确保DbContext、仓储、工作单元都是该任务独有的实例，从根源避免跟踪冲突。

2. 调整DbContext的生命周期为瞬态 #

如果不想为每个任务单独创建作用域，可以将DbContext的生命周期改为Transient，这样每次从DI容器获取都会得到新实例：

services.AddDbContext<ApplicationDBContext>(options =>
    options.UseSqlServer(configuration.GetConnectionString("DefaultConnection"), 
    providers => providers.EnableRetryOnFailure(3, TimeSpan.FromSeconds(10), null)),
    ServiceLifetime.Transient // 修改为瞬态生命周期
);

// 同步调整仓储和工作单元的生命周期为瞬态
services.AddTransient<ISupplierRepository, SupplierRepository>();
services.AddTransient<IUnitOfWork, UnitOfWork>();

注意：瞬态实例会增加对象创建的开销，适合轻量级的数据库操作，且要保证相关依赖的生命周期一致，避免出现上下文被意外共享的情况。

3. 在仓储查询中使用无跟踪模式 #

如果AddMessage中的操作不需要对实体进行后续跟踪（比如仅查询后做判断，不需要修改保存），可以在查询时添加AsNoTracking()，让EF Core不跟踪该实体：

// 仓储中的查询方法示例
public async Task<Supplier> GetSupplierById(int id)
{
    return await _dbContext.Suppliers.AsNoTracking()
        .FirstOrDefaultAsync(s => s.Id == id);
}

这种方式下，实体不会被上下文跟踪，即使多个任务操作同一实体，也不会触发跟踪冲突。

4. 手动分离已跟踪的实体（应急方案） #

如果无法避免共享DbContext的情况，可以在操作前将已被跟踪的实体从上下文分离：

// 在CRUD操作前执行
var existingEntity = await _dbContext.Suppliers.FindAsync(entityId);
if (existingEntity != null)
{
    _dbContext.Entry(existingEntity).State = EntityState.Detached;
}
// 执行后续的CRUD操作

此方法仅适合临时应急，因为手动管理实体状态容易引发其他潜在问题，比如更新丢失、状态不一致等，不推荐作为常规解决方案。

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