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

发布时间：2020-12-15 03:42:20 所属栏目：百科来源：网络整理

导读：我想使用.NET迭代器并行任务/等待？这样的东西 IEnumerableTDst FooTSrc,TDest(IEnumerableTSrc source){ Parallel.ForEach( source,s= { // Ordering is NOT important // items can be yielded as soon as they are done yield return ExecuteOrDownloadSo

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

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!