c# - 运行使用 EF Core 的并行异步任务时出现异常

Question

我正在尝试了解在将数据库上下文注入(inject)到类中时如何处理使用 Entity Framework 的并行异步任务。

我有一个显示总计数量的仪表板，而我想要做的是运行并行返回这些总计的方法。目前我有一些代码如下所示:

public class KpiRepository : IKpiRepository
{
    private readonly kpiContext _context;

    public KpiRepository(kpiContext context)
    {
        _context = context;
    }

    public Task<int> NonCompliantTotalCountAsync()
    {
        return _context.vw_SearchData
            .CountAsync(x => x.NonComplianceDate < DateTime.Today || x.DateDueOutOfService < DateTime.Today);
    }

    public Task<int> NonCompliantInNextWeekCountAsync()
    {
        return NonCompliantBetweenNowAndDateCountAsync(DateTime.Today.AddDays(7));
    }

    public Task<int> NonCompliantInNextMonthCountAsync()
    {
        return NonCompliantBetweenNowAndDateCountAsync(DateTime.Today.AddMonths(1));
    }

    private Task<int> NonCompliantBetweenNowAndDateCountAsync(DateTime endDate)
    {
        return _context.vw_SearchData
            .CountAsync(x => (x.NonComplianceDate >= DateTime.Today && x.NonComplianceDate <= endDate)
                || (x.DateDueOutOfService >= DateTime.Today && x.DateDueOutOfService <= endDate));
    }

    var taskNonCompliantInNextWeekCountAsync = NonCompliantInNextWeekCountAsync();
    var taskNonCompliantInNextMonthCountAsync = NonCompliantInNextMonthCountAsync();  

    Task.WaitAll(
        taskNonCompliantInNextWeekCountAsync,
        taskNonCompliantInNextMonthCountAsync
    );

    data.NonCompliantInNextWeekCount= taskNonCompliantInNextWeekCountAsync.Result;
    data.NonCompliantInNextMonthCount= taskNonCompliantInNextMonthCountAsync.Result;

当我运行该代码时，我从 Task.WaitAll 行收到此错误:

InvalidOperationException: The connection was not closed. The connection's current state is connecting.

在 some reading 之后我意识到 Entity Framework is not thread safe ，所以，我猜导致异常的原因是，当我的每个任务运行时，它们都使用相同的上下文实例，这导致 EF 引发异常？

因此，解决方案似乎是为每个任务创建一个新的上下文实例，但我使用的是依赖注入(inject)，因此默认情况下，我的上下文实例的范围限定为服务器请求的生命周期(我认为)。

那么，上面的理解是否正确，如果是的话，是否是为我的每项任务获取新上下文而不是重用现有任务的解决方案？我该怎么做？

Answer 1

我添加了一个工厂类来创建我的上下文的新实例:

   public class KpiContextFactory: IKpiContextFactory
    {
        private string _connection = @"Server=.\SQL2008EXP;Database=kpiDb;Trusted_Connection=True;";

        public KpiContext GetNewContext()
        {
            var optionsBuilder = new DbContextOptionsBuilder<KpiContext>();
            optionsBuilder.UseSqlServer(_connection);

            return new KpiContext(optionsBuilder.Options);
        }
    }

现在我只注入(inject)工厂而不是上下文本身，然后调用 _kpiContextFactory.GetNewContext().[method] 而不是 _context.[method]。这似乎工作正常。