我想使用.NET迭代器并行任务/等待？这样的东西
IEnumerable<TDst> Foo<TSrc,TDest>(IEnumerable<TSrc> source)
{
Parallel.ForEach(
source,s=>
{
// Ordering is NOT important
// items can be yielded as soon as they are done
yield return ExecuteOrDownloadSomething(s);
}
}
不幸的是.NET不能自己处理这个.最好的答案到目前为止@svick – 使用AsParallel().
解决方法
这似乎是PLINQ的工作：
return source.AsParallel().Select(s => ExecuteOrDownloadSomething(s));
这将使用有限数量的线程并行执行代理,一旦完成就返回每个结果.
如果ExecuteOrDownloadSomething()方法是IO绑定的(例如它实际下载的东西),并且您不想浪费线程,那么使用async-await可能是有意义的,但会更复杂.
如果你想充分利用异步,你不应该返回IEnumerable,因为它是同步的(即如果没有可用的项目就阻止它).您需要的是某种异步集合,您可以使用TPL Dataflow中的ISourceBlock(具体为TransformBlock)：
ISourceBlock<TDst> Foo<TSrc,TDest>(IEnumerable<TSrc> source)
{
var block = new TransformBlock<TSrc,TDest>(
async s => await ExecuteOrDownloadSomethingAsync(s),new ExecutionDataflowBlockOptions
{
MaxDegreeOfParallelism = DataflowBlockOptions.Unbounded
});
foreach (var item in source)
block.Post(item);
block.Complete();
return block;
}
如果源是“慢”(即,您希望在迭代源完成之前开始处理来自Foo()的结果),那么您可能希望将foreach和Complete()调用移到单独的Task中.更好的解决方案是使源程序成为ISourceBlock< TSrc>太.
