c# - 以任何顺序短路等待所有任务

Question

我需要对网络服务进行一系列调用以获得一组节点计数。我正在并行、异步地进行所有调用。发起调用后，我会像这样总结结果:

//pendingTasks is List<Task<int>>
int sum = 0;
foreach (var task in pendingTasks)
{
    sum += await task;
    if (sum > 100) break;
}

break就在那里，因为我不关心超过100之后的具体计数。

首先，像那样跳出循环是否危险？留下未决任务不好吗？它会造成任何类型的内存泄漏吗？

其次，个别调用相当不一致。如果第一个电话是最长的，我会讨厌它，我最终会等待它，即使所有后续电话总和超过 100。随着个人结果的返回，添加到总和会很好，在他们收到的顺序。我以前用过 WhenAll ，我很确定 WhenAny 是我想要的，但我不太确定如何在我想要的这种场景中使用它在它们进来时处理多个，然后在它们全部完成时终止。

Answer 1

First off, is it dangerous to break out of the loop like that? Is it bad to leave pending tasks? Will it create a memory leak of any kind?

它不会造成内存泄漏，但如果任务有与之关联的取消 token ，则取消它们以避免不必要地完成额外工作会很有用。

在 .NET 4 中，出现故障但没有“观察到”这些故障的任务将默认(故意)关闭进程，但 .NET 4.5 放宽了这一点。

I have used WhenAll before, and I am pretty sure WhenAny Is what I want, but I am not quite sure how to use it in this kind of scenario, where I want to process multiple as they come in, and then terminate when they are all done.

WhenAny 当然可以在这里为你工作，但另一种方法是“神奇地”重新排序任务，这样你就可以按照它们的顺序迭代它们完全的。或者更确切地说，按完成顺序迭代得到与原始任务相同结果的新任务。

我写了一个blog post on that very topic不久前——虽然这不是我的主意。基本上，您创建了一堆 TaskCompletionSource 对象 - 每个原始任务一个 - 并向每个原始任务添加一个延续，以填充“下一个可用”任务完成源。

有关如何使用 WhenAny 的示例，您可以查看我的 majority voting博客文章 - 但缺点是有很多集合操作，并且 n 调用 WhenAny。 “神奇的重新排序”创建了一个新的任务集合，但随后只是为每个原始任务附加了一个延续，所以没有什么真正等待所有这些......你可以一次迭代一个，等待每个依次一个。