草庐IT

c# - Parallel.For 和 Break() 的误解？

coder 2024-06-01 原文

我正在研究 For 循环中的并行中断。

看完this 和 this我还有一个问题:

我希望这段代码:

 Parallel.For(0, 10, (i,state) =>  
     { 
                Console.WriteLine(i); if (i == 5) state.Break(); 
     }

最多生成 6 个数字 (0..6)。 不仅他没有这样做，而且结果长度不同:

02351486
013542
0135642

非常烦人。 (Break() {after 5} 到底在哪里？？)

于是我看了一下msdn

Break may be used to communicate to the loop that no other iterations after the current iteration need be run. If Break is called from the 100th iteration of a for loop iterating in parallel from 0 to 1000, all iterations less than 100 should still be run, but the iterations from 101 through to 1000 are not necessary.

问题#1:

哪些迭代？整体迭代计数器？还是每个线程？我很确定这是每个线程。请批准。

问题#2:

假设我们正在使用并行 + 范围分区(由于元素之间的 cpu 成本没有变化)，因此它在线程之间划分数据。所以如果我们有 4 个核心(并且在它们之间完美划分):

core #1 got 0..250
core #2 got 251..500
core #3 got 501..750
core #4 got 751..1000

因此 core #1 中的线程将在某个时候遇到 value=100 并中断。 这将是他的迭代编号 100 。 但是 core #4 中的线程获得了更多的量子，他现在在 900 上。他远超他的第 100 次 迭代。 他没有索引减去 100 被阻止!! - 所以他会展示给他们看。

我说得对吗？这就是我在示例中获得超过 5 个元素的原因吗？

问题#3:

当 (i == 5) 时，我如何真正崩溃？

附:

我的意思是，来吧!当我执行 Break() 时，我希望循环停止。 与我在常规 For 循环中所做的完全一样。

最佳答案

To yield at most 6 numbers (0..6).

问题是这不会产生最多 6 个数字。

发生的事情是，当您遇到索引为 5 的循环时，您会发送“中断”请求。 Break()将导致循环不再处理任何值 >5 ，但处理所有值 <5 .

但是，任何已经开始的大于 5 的值仍将得到处理。由于各种索引并行运行，它们不再有序，所以你会得到各种运行，其中一些值 >5 (例如您示例中的 8)仍在执行中。

Which iterations ? the overall iteration counter ? or per thread ? I'm pretty sure it is per thread. please approve.

这是传递给 Parallel.For 的索引。 Break() 不会阻止处理项目，但会保证处理最多 100 个项目，但可能会处理也可能不会处理超过 100 个的项目。

Am I right ? is that is the reason why I get more than 5 elements in my example ?

是的。如果你像你展示的那样使用分区器，只要你调用 Break() ，您打破的项目将不再被安排。但是，已安排的项目(即整个分区)将得到完全处理。在您的示例中，这意味着您可能始终处理所有 1000 个项目。

How can I truly break when (i == 5) ?

你是 - 但当你并行运行时，事情就变了。这里的实际目标是什么？如果您只想处理前 6 个项目 (0-5)，您应该在通过 LINQ 查询或类似查询循环遍历它们之前限制这些项目。然后您可以处理 Parallel.For 中的 6 个项目或 Parallel.ForEach没有 Break()不用担心。

I mean , come on ! when I do Break() , I want things the loop to stop. excactly as I do in regular For loop.

你应该使用 Stop() 而不是 Break()如果你想让事情尽快停止。这不会阻止项目停止已经运行，但不会再安排任何项目(包括索引较低或枚举中比您当前位置更早的项目)。

关于c# - Parallel.For 和 Break() 的误解？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/12784530/

c#ParallelcodeblockquoteBreak.net.net-4.0parallel-processingtask-parallel-library

有关c# - Parallel.For 和 Break() 的误解？的更多相关文章

  1. ruby-on-rails - form_for 中不在模型中的自定义字段 - 2

    我想向我的Controller传递一个参数，它是一个简单的复选框，但我不知道如何在模型的form_for中引入它，这是我的观点:{:id=>'go_finance'}do|f|%>Transferirde:para:Entrada:"input",:placeholder=>"Quantofoiganho?"%>Saída:"output",:placeholder=>"Quantofoigasto?"%>Nota:我想做一个额外的复选框，但我该怎么做，模型中没有一个对象，而是一个要检查的对象，以便在Controller中创建一个ifelse，如果没有检查，请帮助我，非常感谢,谢谢

  2. ruby-on-rails - Rails 中的 NoMethodError::MailersController#preview undefined method `activation_token=' for nil:NilClass - 2

    似乎无法为此找到有效的答案。我正在阅读Rails教程的第10章第10.1.2节，但似乎无法使邮件程序预览正常工作。我发现处理错误的所有答案都与教程的不同部分相关，我假设我犯的错误正盯着我的脸。我已经完成并将教程中的代码复制/粘贴到相关文件中，但到目前为止，我还看不出我输入的内容与教程中的内容有什么区别。到目前为止，建议是在函数定义中添加或删除参数user，但这并没有解决问题。触发错误的url是http://localhost:3000/rails/mailers/user_mailer/account_activation.http://localhost:3000/rails/mai

  3. c# - 如何在 ruby​​ 中调用 C# dll？ - 2

    如何在ruby​​中调用C#dll？ 最佳答案 我能想到几种可能性:为您的DLL编写(或找人编写)一个COM包装器，如果它还没有，则使用Ruby的WIN32OLE库来调用它；看看RubyCLR,其中一位作者是JohnLam，他继续在Microsoft从事IronRuby方面的工作。(估计不会再维护了，可能不支持.Net2.0以上的版本)；正如其他地方已经提到的，看看使用IronRuby，如果这是您的技术选择。有一个主题是here.请注意，最后一篇文章实际上来自JohnLam(看起来像是2009年3月)，他似乎很自在地断言RubyCL

  4. ruby-on-rails - 如何重命名或移动 Rails 的 README_FOR_APP - 2

    当我在我的Rails应用程序根目录中运行rakedoc:app时，API文档是使用/doc/README_FOR_APP作为主页生成的。我想向该文件添加.rdoc扩展名，以便它在GitHub上正确呈现。更好的是，我想将它移动到应用程序根目录(/README.rdoc)。有没有办法通过修改包含的rake/rdoctask任务在我的Rakefile中执行此操作？是否有某个地方可以查找可以修改的主页文件的名称？还是我必须编写一个新的Rake任务？额外的问题:Rails应用程序的两个单独文件/README和/doc/README_FOR_APP背后的逻辑是什么？为什么不只有一个？

  5. C# 到 Ruby sha1 base64 编码 - 2

    我正在尝试在Ruby中复制Convert.ToBase64String()行为。这是我的C#代码:varsha1=newSHA1CryptoServiceProvider();varpasswordBytes=Encoding.UTF8.GetBytes("password");varpasswordHash=sha1.ComputeHash(passwordBytes);returnConvert.ToBase64String(passwordHash);//returns"W6ph5Mm5Pz8GgiULbPgzG37mj9g="当我在Ruby中尝试同样的事情时，我得到了相同sha

  6. ruby-on-rails - 复数 for fields_for has_many 关联未显示在 View 中 - 2

    目前，Itembelongs_toCompany和has_manyItemVariants。我正在尝试使用嵌套的fields_for通过Item表单添加ItemVariant字段，但是使用:item_variants不显示该表单。只有当我使用单数时才会显示。我检查了我的关联，它们似乎是正确的，这可能与嵌套在公司下的项目有关，还是我遗漏了其他东西？提前致谢。注意:下面的代码片段中省略了不相关的代码。编辑:不知道这是否相关，但我正在使用CanCan进行身份验证。routes.rbresources:companiesdoresources:itemsenditem.rbclassItemi

  7. 基于C#实现简易绘图工具【100010177】 - 2

    C#实现简易绘图工具一.引言实验目的:通过制作窗体应用程序(C#画图软件),熟悉基本的窗体设计过程以及控件设计,事件处理等,熟悉使用C#的winform窗体进行绘图的基本步骤,对于面向对象编程有更加深刻的体会.Tutorial任务设计一个具有基本功能的画图软件**·包括简单的新建文件,保存,重新绘图等功能**·实现一些基本图形的绘制,包括铅笔和基本形状等,学习橡皮工具的创建**·设计一个合理舒适的UI界面**注明:你可能需要先了解一些关于winform窗体应用程序绘图的基本知识,以及关于GDI+类和结构的知识二.实验环境Windows系统下的visualstudio2017C#窗体应用程序三.

  8. ruby - Ruby 中的闭包和 for 循环 - 2

    我是Ruby的新手，有些闭包逻辑让我感到困惑。考虑这段代码:array=[]foriin(1..5)array[5,5,5,5,5]这对我来说很有意义，因为i被绑定(bind)在循环之外，所以每次循环都会捕获相同的变量。使用每个block可以解决这个问题对我来说也很有意义:array=[](1..5).each{|i|array[1,2,3,4,5]...因为现在每次通过时都单独声明i。但现在我迷路了:为什么我不能通过引入一个中间变量来修复它？array=[]foriin1..5j=iarray[5,5,5,5,5]因为j每次循环都是新的，我认为每次循环都会捕获不同的变量。例如，这绝对

  9. ruby-on-rails - rails 上的 ruby : radio buttons for collection select - 2

    我有一个集合选择:此方法的单选按钮是什么？谢谢 最佳答案 Rails3中没有这样的助手。在Rails4中，它是collection_radio_buttons. 关于ruby-on-rails-rails上的ruby:radiobuttonsforcollectionselect，我们在StackOverflow上找到一个类似的问题： https://stackoverflow.com/questions/18525986/

  10. ruby - [1,2,3].to_enum 和 [1,2,3].enum_for 在 Ruby 中的区别 - 2

    在Ruby中，我试图理解to_enum和enum_for方法。在我提出问题之前，我提供了一些示例代码和两个示例来帮助理解上下文。示例代码:#replicatesgroup_bymethodonArrayclassclassArraydefgroup_by2(&input_block)returnself.enum_for(:group_by2)unlessblock_given?hash=Hash.new{|h,k|h[k]=[]}self.each{|e|hash[input_block.call(e)]示例#1:irb(main)>puts[1,2,3].group_by2.ins

随机推荐