等待异步操作

Question

我有一个静态的泛型方法，用于并行地对集合执行一个操作(不要担心节流；我已经讨论过了；这里的代码是哑巴版本)：

public static IEnumerable<Task> RunAllAsync<T>(this IEnumerable<T> enumerable, Action<T> action)
{
    var tasks = new List<Task>();
    foreach (var t in enumerable)
    {
        tasks.Add(Task.Run(() => action(t)));
    }
    return tasks;
}

下面是一个如何使用的示例：

public async Task UsageSync()
{
    var numbers = Enumerable.Range(1, 5);
    var random = new Random();
    var tasks = numbers.RunAllAsync(i =>
                                    {
                                        Console.WriteLine($"A {i}");
                                        Thread.Sleep(random.Next(1000));
                                        Console.WriteLine($"B {i}");
                                    });
    Console.WriteLine("Awaiting end");
    await Task.WhenAll(tasks.ToArray());
    Console.WriteLine("awaited");
    Thread.Sleep(2000);
    Console.WriteLine("Finished");
}

输出：

Awaiting end
A 4
A 5
A 1
A 2
A 3
B 3
B 2
B 1
B 5
B 4
awaited
Finished

一切如愿以偿。但是，现在我们将该操作本身设置为异步委托：

public async Task UsageAsync()
{
    var numbers = Enumerable.Range(1, 5);
    var random = new Random();
    var tasks = numbers.RunAllAsync(async i =>
                                    {
                                        Console.WriteLine($"A {i}");
                                        await Task.Run(() =>
                                                       {
                                                           Console.WriteLine($"B {i}");
                                                           Thread.Sleep(random.Next(1000));
                                                           Console.WriteLine($"C {i}");
                                                       });
                                    });
    Console.WriteLine("Awaiting end");
    await Task.WhenAll(tasks.ToArray());
    Console.WriteLine("awaited");
    Thread.Sleep(2000);
    Console.WriteLine("Finished");
}

输出：

Awaiting end
A 4
B 4
A 1
A 5
A 3
A 2
B 2
awaited
B 5
B 1
B 3
C 3
C 2
C 1
C 5
C 4
Finished

看到了吗？在线程完成之前，这个方法达到了“等待”！

我应该做些什么来确保等待异步操作？

Answer 1

由于您处理的是Action<T>，所以async i => { ... }会被转换为async void方法。async void的设计使它不可能等待它完成。将参数更改为Func<T, Task> func，并将调用action(t)更改为await func(t)。