C# · 12月 29, 2021

c# – 如何从.NET 4.5中的并行任务中获得收益

我想使用.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>太.