Jak oczekiwać na listę zadań asynchronicznie przy użyciu LINQ?

Mam listę zadań, które utworzyłem w ten sposób:

public async Task<IList<Foo>> GetFoosAndDoSomethingAsync()
{
    var foos = await GetFoosAsync();

    var tasks = foos.Select(async foo => await DoSomethingAsync(foo)).ToList();

    ...
}

Po użyciu .ToList()wszystkie zadania powinny się rozpocząć. Teraz chcę poczekać na ich zakończenie i zwrócić wyniki.

Działa to w powyższym ...bloku:

var list = new List<Foo>();
foreach (var task in tasks)
    list.Add(await task);
return list;

Robi, co chcę, ale wydaje się to raczej niezdarne. Wolałbym napisać coś prostszego:

return tasks.Select(async task => await task).ToList();

... ale to się nie kompiluje. czego mi brakuje? A może po prostu nie można tego wyrazić w ten sposób?

LINQ nie działa idealnie z asynckodem, ale możesz to zrobić:

var tasks = foos.Select(DoSomethingAsync).ToList();
await Task.WhenAll(tasks);

Jeśli wszystkie zadania zwracają ten sam typ wartości, możesz nawet zrobić to:

var results = await Task.WhenAll(tasks);

co jest całkiem miłe. WhenAllzwraca tablicę, więc uważam, że twoja metoda może zwrócić wyniki bezpośrednio:

return await Task.WhenAll(tasks);

Aby rozwinąć odpowiedź Stephena, stworzyłem następującą metodę rozszerzenia, aby zachować płynny styl LINQ. Możesz to zrobić

await someTasks.WhenAll()

namespace System.Linq
{
    public static class IEnumerableExtensions
    {
        public static Task<T[]> WhenAll<T>(this IEnumerable<Task<T>> source)
        {
            return Task.WhenAll(source);
        }
    }
}

Jednym z problemów z Task.WhenAll jest to, że stworzyłoby to równoległość. W większości przypadków może być nawet lepiej, ale czasami chcesz tego uniknąć. Na przykład odczytywanie danych partiami z bazy danych i wysyłanie danych do niektórych zdalnych usług internetowych. Nie chcesz ładować wszystkich partii do pamięci, ale trafisz do bazy danych po przetworzeniu poprzedniej partii. Więc musisz przełamać asynchroniczność. Oto przykład:

var events = Enumerable.Range(0, totalCount/ batchSize)
   .Select(x => x*batchSize)
   .Select(x => dbRepository.GetEventsBatch(x, batchSize).GetAwaiter().GetResult())
   .SelectMany(x => x);
foreach (var carEvent in events)
{
}

Uwaga .GetAwaiter (). GetResult () konwertuje go na synchronizację. DB zostałby uderzony leniwie tylko po przetworzeniu zdarzeń batchSize.

Użyj Task.WaitAlllub Task.WhenAllcokolwiek jest odpowiednie.

Zadanie Kiedy wszyscy powinni tutaj załatwić sprawę.