【问题标题】:Sequential iteration (Parallel.For())顺序迭代(Parallel.For())
【发布时间】:2014-07-10 13:11:49
【问题描述】:

这段代码的输出每次都不同。是否可以从 0 到 21 顺序输出 i(迭代计数)?

  static void Main(string[] args)
    {

        int N = 1000;
            Parallel.For(0, N, (i, loop) =>
            {
                Console.WriteLine(i);
                if (i == 21)
                {
                    loop.Break();
                }
            });
            Console.ReadLine();
    }

【问题讨论】:

  • 是的,这是可能的——不要使用并行。您要么需要以未定义的顺序并行执行,要么需要以已定义的顺序执行。
  • 但是如果不使用parallel,那么它将是简单的For()循环。
  • 并行会为每次迭代创建线程,无法保证线程的执行顺序。
  • 如果我想执行前 (0-5) 五次迭代,然后执行最后 (17-21) 五次迭代,然后是剩余的迭代,我该怎么做? 0,1,2,3,4,5,17,18,19,20,21,....的顺序输出。
  • "但是如果不使用并行,那么它将是简单的 For() 循环" --- 完全正确。这就是你想要的。

标签: c# parallel.for


【解决方案1】:

当使用 Parallel.For 方法时,不能保证特定的执行顺序。优点是循环在具有可用内核的计算机上完成得更快,因为这些步骤通常同时并行进行。您仍然可以保证所有循环的迭代将在循环完成时运行,但不能保证它们将运行的顺序。如果你想运行一个顺序循环,那么你应该使用for

【讨论】:

  • 谢谢。我现在很清楚,除了使用 For() 我别无选择
【解决方案2】:

改用 foreach 循环:

foreach (var VARIABLE in (Enumerable.Range(0, 10).AsParallel().AsOrdered()))
{
    Console.WriteLine(VARIABLE);
}

带索引的示例

foreach (var obj in Enumerable.Range(0, 10)
    .Select((s, i) => new {index = i, value = s})
    .AsParallel()
    .Select(obj => new {obj.index, value = obj.value*obj.value, thread=Thread.CurrentThread.ManagedThreadId})
    .OrderBy(o => o.index))
{
    Console.WriteLine("{0}:{1} on {2}", obj.index, obj.value, obj.thread);
}

Core i7 的结果。

0:0 on 1
1:1 on 3
2:4 on 5
3:9 on 1
4:16 on 1
5:25 on 1
6:36 on 1
7:49 on 1
8:64 on 1
9:81 on 1

【讨论】:

  • 一个问题,如果我在每次迭代中执行一些完全相同的操作并将结果添加到数组中,每次迭代的返回值是否也会在数组中排序?
  • 我建议您添加一个排序索引,并行执行,而不是按该索引排序。它将执行得更快。
  • 听起来正是我所需要的。你能帮我一个代码示例吗?或链接可能有助于构建此代码。
  • 线程的值在每次迭代中都是一样的。您每次都在一个线程中启动每次迭代吗? ---
  • 也许你的电脑资源比我的少……我的电脑显示了 3-4 个不同的线程 ID。尝试使用更多元素或每个元素更长的处理时间。
猜你喜欢
  • 1970-01-01
  • 1970-01-01
  • 2012-10-31
  • 1970-01-01
  • 2016-01-18
  • 2012-12-28
  • 2011-02-11
  • 1970-01-01
  • 1970-01-01
相关资源
最近更新 更多