Parallel.For 和 Break() 误解？

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

看完之后this http://tipsandtricks.runicsoft.com/CSharp/ParallelClass.html and this http://reedcopsey.com/2010/01/22/parallelism-in-net-part-3-imperative-data-parallelism-early-termination/我还有一个问题：

我期望这段代码：

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

屈服于most6 个数字 (0..6)。 他不仅没有这样做，而且结果长度也不同：

02351486
013542
0135642

很烦人。 （Break() {after 5} 到底在哪里？？）

于是我看了一下msdn

Break 可用于向循环传达当前迭代之后不需要运行其他迭代的信息。 如果从 for 循环的第 100 次迭代开始调用 Break 从 0 到 1000 并行，所有小于 100 的迭代仍然应该是 运行，但从 101 到 1000 的迭代是不必要的。

Quesion #1 :

哪些迭代？总体迭代计数器 ?或每个线程？我很确定它是每个线程的。请批准。

Question #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现在。他是远远超出 his 100'th迭代。 他的指数没有低于 100 就可以被阻止！ -所以他会向他们展示全部。

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

Question #3 :

我怎样才能真正打破(i == 5) ?

p.s.

我的意思是，来吧！当我做Break()，我希望循环停止。 和我平常做的一样For loop.

最多产生 6 个数字 (0..6)。

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

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

但是，任何已启动的大于 5 的值仍将得到处理。由于各种索引并行运行，它们不再排序，因此您会得到各种运行，其中某些值>5（例如您示例中的 8）仍在执行。

哪些迭代？总体迭代计数器 ?或每个线程？我很确定它是每个线程的。请批准。

这是传递给 Parallel.For 的索引。 Break() 不会prevent项目不被处理，但保证 100 以内的所有项目都得到处理，但 100 以上的项目可能会也可能不会被处理。

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

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

当 (i == 5) 时我怎样才能真正打破？

你是 - 但当你并行运行时，事情就会发生变化。是什么实际目标这里？如果您只想处理前 6 项（0-5），则应该限制这些项before您可以通过 LINQ 查询或类似查询循环遍历它们。然后您可以处理 6 个项目Parallel.For or Parallel.ForEach没有Break()并且无忧无虑。

我的意思是，来吧！当我执行 Break() 时，我希望循环停止。正如我在常规 For 循环中所做的那样。

你应该使用Stop() http://msdn.microsoft.com/en-us/library/system.threading.tasks.parallelloopstate.stop.aspx代替Break()如果你想让事情尽快停止。这不会阻止物品已经运行停止，但将不再安排任何项目（包括索引较低或枚举中比您当前位置更早的项目）。