EF核心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中，我正在注册db和存储库

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();            
   }
   ...
}

在控制器操作上，我试图执行并行预测

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();
    }
}

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

对于异步方法，我没有任何期待已久的调用。我的存储库和DB上下文被注册为瞬态的。

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

我做错什么了？

Answer 1

我做错什么了？

正如错误消息所指出的，您的代码同时调用一个DbContext上的多个方法。具体来说，它同时多次调用_carRepository.GetById。

最好的解决方案是重组查询/存储库，使其能够处理大容量操作。例如，您需要一个大容量检索路径，将所有ids发送到数据库，然后取回所有的汽车。这通常是最简单的，如果您放弃错误的通用存储库反模式，而只是直接使用EF。