Асинхронно обрабатывать объекты, поскольку они возвращаются из механизма базы данных.

Question

В EF 6 я хотел бы асинхронно обрабатывать объекты по мере их возврата из механизма базы данных.

Я знаю, что могу позвонить ToListAsync() и ForEachAsync() и, возможно, они делают то, что ищу, но я не уверен. Я думаю, что я ищу, это сочетание двух.

С моей точки зрения, ToListAsync() выполнит задачу, когда весь запрос будет прочитан из механизма базы данных и преобразован в объекты. Это означает, что вам нужно дождаться возврата всего запроса до начала процесса.

Я не могу определить, выполняет ли ForEachAsync() то, что я ищу, но то, что я предполагаю, из-за отсутствия информации в другом месте, заключается в том, что ForEachAsync() просто работает с уже полученной коллекцией, и обработка каждого элемента асинхронна ,

Что было бы идеальным, так это то, что ForEachAsync() (или другой, но неизвестный метод) вызовет задачу, поскольку данные извлекаются из механизма базы данных.

Итак, действительно ли это ForEachAsync(), а если нет, есть ли способ для этого?

Причины желания этого являются два аспекта:

1. Большие запросы не должны быть сохранены в памяти, как и весь коллекции, так что экономия объема памяти и способности обрабатывать гораздо больше результирующих не ограничен памятью
2. продолжительность всего процесса , вероятно, будет короче, за счет обработки каждого элемента во время латентности поиска данных

Обновление: В принципе, если DbContext поднял событие, например, OnEntityLoaded для каждого объекта, когда вы позвонили LoadAsync(), я мог бы выполнить все, что захочу. Поскольку я мог бы просто вставить объект в отдельный процессор задач, и сущности могли бы эффективно обрабатываться и использовать любую задержку ввода-вывода. Я всегда могу настроить отдельный процессор задач, поэтому мне не нужен EF для поддержки асинхронной обработки сущностей, просто асинхронно загружать и запускать событие/вызывать делегат при загрузке каждого объекта.

Обновление 2: И если ForEachAsync() было вызвано, как сущности загружались, то это также выполнило бы то, что я хочу.

Answer 1

ForEachAsync, в отличие от ToListAsync, не получает все предметы заранее и просто позволяет вам перебирать его. Итерация составляет async.

QueryableExtensions.ForEachAsync делегатов к IDbAsyncEnumerable.ForEachAsyncwhich is this:

internal static async Task ForEachAsync(
    this IDbAsyncEnumerable source, Action<object> action, CancellationToken cancellationToken) 
{ 
    DebugCheck.NotNull(source); 
    DebugCheck.NotNull(action); 

    cancellationToken.ThrowIfCancellationRequested(); 

    using (var enumerator = source.GetAsyncEnumerator()) 
    { 
     if (await enumerator.MoveNextAsync(cancellationToken).WithCurrentCulture()) 
     { 
      Task<bool> moveNextTask; 
      do 
      { 
       cancellationToken.ThrowIfCancellationRequested(); 
       var current = enumerator.Current; 
       moveNextTask = enumerator.MoveNextAsync(cancellationToken); 
       action(current); 
      } 
      while (await moveNextTask.WithCurrentCulture()); 
     } 
    } 
} 

Вы можете видеть, что это очень похоже на то, как производится итерация над IEnumerable но async-await в виду.Вместо IEnumerable, GetEnumerator, IEnumerator и MoveNext у нас есть IDbAsyncEnumerable, GetAsyncEnumerator, IDbAsyncEnumerator и MoveNextAsync.

MoveNextAsync позволяет фактически асинхронно извлекать элементы по мере необходимости.