¿Cómo esperar una lista de tareas de forma asincrónica usando LINQ?

Tengo una lista de tareas que creé así:

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

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

    ...
}

Al usar .ToList(), todas las tareas deberían comenzar. Ahora quiero esperar su finalización y devolver los resultados.

Esto funciona en el ...bloque anterior :

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

Hace lo que quiero, pero esto parece bastante torpe. Prefiero escribir algo más simple como esto:

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

... pero esto no se compila. ¿Qué me estoy perdiendo? ¿O simplemente no es posible expresar las cosas de esta manera?

LINQ no funciona perfectamente con asynccódigo, pero puede hacer esto:

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

Si todas sus tareas devuelven el mismo tipo de valor, incluso puede hacer esto:

var results = await Task.WhenAll(tasks);

lo cual es bastante agradable. WhenAlldevuelve una matriz, por lo que creo que su método puede devolver los resultados directamente:

return await Task.WhenAll(tasks);

Para ampliar la respuesta de Stephen, he creado el siguiente método de extensión para mantener el estilo fluido de LINQ. Entonces puedes hacer

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

Un problema con Task.WhenAll es que crearía un paralelismo. En la mayoría de los casos, puede que sea incluso mejor, pero a veces desea evitarlo. Por ejemplo, leer datos en lotes de DB y enviar datos a algún servicio web remoto. No desea cargar todos los lotes en la memoria, pero presione la base de datos una vez que se haya procesado el lote anterior. Entonces, debes romper la asincronicidad. Aquí hay un ejemplo:

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)
{
}

Tenga en cuenta que .GetAwaiter (). GetResult () lo convierte en sincronizado. DB se golpearía de forma perezosa solo una vez que se haya procesado batchSize de eventos.

Use Task.WaitAllo Task.WhenAlllo que sea apropiado.

Task.WhenAll debería hacer el truco aquí.