实体框架6、加载实体async/await

Question

我想从 db 重新加载某些实体，因为我想使用 async/await 重新加载它们的长时间操作。这是我的代码：

private async void btnUpdate_Click(object sender, EventArgs e)
{
 Task allTasks = UpdateAppointments();
 await allTasks;
}
 internal async Task UpdateAppointments()
 {

        IEnumerable<Entities.Apointment> apps = PContext.Appointments.Select(p => p).Where(p => p.Start >= Start && p.End <= End && p.MachineId == 66);

        List<Task> task = new List<Task>();

        foreach (Entities.Apointment app in apps)
        {

            task.Add(PContext.Entry(app).ReloadAsync());

        }
        await Task.WhenAll(task);
    }

我得到错误：

在前一个异步操作完成之前，在此上下文上启动了第二个操作。使用“等待”确保任何 异步操作在调用另一个方法之前已经完成 在这种情况下。不保证任何实例成员都是线程 安全。**

异常详情：

{System.NotSupportedException：在前一个异步操作完成之前，在此上下文上启动了第二个操作。使用 'await' 确保在此上下文中调用另一个方法之前所有异步操作都已完成。不保证任何实例成员都是线程安全的。 在 System.Data.Entity.Internal.ThrowingMonitor.EnsureNotEntered() 在 System.Data.Entity.Core.Objects.ObjectContext.RefreshAsync（刷新模式刷新模式，对象实体，CancellationToken 取消令牌） 在 System.Data.Entity.Internal.InternalEntityEntry.ReloadAsync（CancellationToken cancelToken） 在 System.Data.Entity.Infrastructure.DbEntityEntry`1.ReloadAsync() 在 C:\Git\planningmodule\PlanningModule\PlanningForm.cs:line 307 中的 PlanningModule.PlanningForm.d__20.MoveNext() --- 从先前抛出异常的位置结束堆栈跟踪 --- 在 System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess（任务任务） 在 System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification（任务任务） 在 System.Runtime.CompilerServices.TaskAwaiter.GetResult() 在 C:\Git\planningmodule\PlanningModule\PlanningForm.cs:line 264 中的 PlanningModule.PlanningForm.d__19.MoveNext() }

内部异常：

空

堆栈跟踪：

_stackTrace {sbyte[192]} 对象 {sbyte[]}

任何想法，如何异步重新加载实体？

Answer 1

您必须先实现该列表，然后才能对该 DbContext 执行其他操作，因为在您枚举 IQueryable 时正在积极使用 DbContext。因此，添加.ToList() 将解决问题，因为在迭代开始之前，所有实体都会从DbContext 中检索出来。

foreach (Entities.Apointment app in apps.ToList()) // added ToList()

如果您想使用 async 实现列表，您可以这样做

foreach (Entities.Apointment app in (await apps.ToListAsync()))

编辑 来自 cmets

我应该注意，我得到的错误通常与许多正在重新加载的实体有关 (>1000)

我能想到的唯一另一件事是await Task.WhenAll(task); 中存在竞争条件，其中任务（您在此语句之前的循环中定义）同时调用DbContext .如果没有其他信息，我不能肯定地告诉你（让我知道它是完全相同的错误还是不同的错误）。在这种情况下，您应该在循环内同步执行每个调用，这仍然可以使用 await/async 调用来完成。

// note, for readability I changed the explicit types to keyword var to make the code a little more compact and hopefully easier identify the changes
var apps = await PContext.Appointments.Select(p => p).Where(p => p.Start >= Start && p.End <= End && p.MachineId == 66).ToListAsync(); // Retrieve all instances on the context in one call

foreach (var app in apps)
{
    await PContext.Entry(app).ReloadAsync(); // execute each Reload synchronously instead of concurrently
}