如何等待并行 Linq 操作完成

Question

我不确定我应该如何混合 plinq 和 async-await。假设我有如下界面

public interface IDoSomething (
    Task Do();
}

我有一个列表，我想并行执行并能够await 完成所有操作。

public async Task DoAll(IDoSomething[] doers) {
    //Execute all doers in parallel ideally using plinq and 
    //continue when all are complete
}

如何实现？我不确定如何从并行 linq 转到 Tasks，反之亦然。

我并不十分担心异常处理。理想情况下，第一个会触发并破坏整个过程，因为我计划在出错时丢弃整个过程。

编辑：很多人都在说Task.WaitAll。我知道这一点，但我的理解（除非有人可以证明）是它不会主动为您将事情并行化到多个可用的处理器内核。我具体要问的是双重的 -

1. 如果我在 Plinq 操作中 await 和 Task 是否会失去很多优势，因为它会安排一个新线程？

2. 如果我 doers.AsParallel().ForAll(async d => await d.Do()) 平均需要大约 5 秒，我如何不同时旋转调用线程？

Answer 1

你要找的是这个：

public Task DoAllAsync(IEnumerable<IDoSomething> doers)
{
    return Task.WhenAll(doers.Select(doer => Task.Run(() => doer.Do())));
}

使用Task.Run 将使用ThreadPool 线程并行执行async 方法Do 的每个同步部分，而Task.WhenAll 异步等待同时执行的异步部分。

---

这是一个好主意仅如果您在这些 async 方法（即 await 之前的部分）中有大量同步部分，例如：

async Task Do()
{
    for (int i = 0; i < 10000; i++)
    {
        Math.Pow(i,i);
    }

    await Task.Delay(10000);
}

否则，不需要并行性，您可以同时触发异步操作并使用 Task.WhenAll 等待所有返回的任务：

public Task DoAllAsync(IEnumerable<IDoSomething> doers)
{
    return Task.WhenAll(doers.Select(doer => doer.Do()));
}

Answer 2

public async Task DoAll(IDoSomething[] doers) {
    //using ToArray to materialize the query right here
    //so we don't accidentally run it twice later.
    var tasks = doers.Select(d => Task.Run(()=>d.Do())).ToArray();
    await Task.WhenAll(tasks);
}