EF Core DbContext 和 Parallel.ForEachAsync 问题

Question

public class CarRepository<Car> : ICarRepository
{
   ....
   public async Task<Car?> GetById(TId id, CancellationToken cancellationToken)
   {
      return await _dbContext.Cars().FindAsync(id, cancellationToken);            
   }
}

在 Program.cs 中我正在注册数据库和存储库

var builder = WebApplication.CreateBuilder(args);
...
builder.Services.AddDbContext<MyDbContext>(options =>
{
   options.UseSqlServer("conn-string");
}, ServiceLifetime.Transient);

builder.Services.AddTransient<ICarRepository, CarRepository>();

DbContext配置如下

public class MyDbContext: DbContext
{
   public MyDbContext(DbContextOptions<MyDbContext> options)
        : base(options)
   {
        Database.EnsureCreated();            
   }
   ...
}

在控制器操作上，我尝试执行并行 foreach

public class CarController : ControllerBase
{
    private ICarRepository _repository;
    public CarController(ICarRepository repository)
    {
       _repository = repository;
    }

    [HttpGet]
    public async Task<IActionResult> Get()
    {
        ParallelOptions parallelOptions = new()
        {
            MaxDegreeOfParallelism = 3
        };

       var cars = new List<Car>();
       await Parallel.ForEachAsync(request.CarIds, parallelOptions, async (id, _) =>
       {
           Car? car = await _carRepository.GetById(id, cancellationToken);
           if (car != null)
           { 
             cars.Add(car); 
           }
       });

       return Ok();
    }
}

System.InvalidOperationException：第二个操作已启动 上一个操作完成之前的此上下文实例。这是 通常是由不同线程同时使用相同的线程引起的 DbContext 的实例。 有关如何避免线程的更多信息 DbContext 的问题，请参阅 https://go.microsoft.com/fwlink/?linkid=2097913。

我没有对异步方法进行任何非等待的调用。 我的存储库和数据库上下文已注册为 Transient。

每个“正常”顺序而不是并行按预期工作，没有错误。

我做错了什么？

Answer 1

我做错了什么？

如错误消息所示，您的代码正在同时调用

DbContext

上的多个方法。具体来说，它同时调用

_carRepository.GetById

多次。

最好的解决方案是重组您的查询/存储库，以便它处理批量操作。例如，您想要一个批量检索路线，将“所有” ID 发送到数据库，然后返回“所有”汽车。如果您放弃被误导的通用存储库反模式并直接使用 EF Core，这通常是最简单的。 我迟到了，看到了答案检查，但看起来你的问题是列表。它不是线程安全的。

Answer 2

我认为你可以使用 ConcurrentBag 代替列表。