For 循环超出范围

Question

using System;
using System.Collections.Generic;
using System.Text;
using System.Threading.Tasks;

namespace ConsoleApplication1
{
    class Program
    {
        static void Main(string[] args)
        {
            MyClass myClass = new MyClass();
            myClass.StartTasks();
        }
    }
    class MyClass
    {
        int[] arr;
        public void StartTasks()
        {
            arr = new int[2];
            arr[0] = 100;
            arr[1] = 101;

            for (int i = 0; i < 2; i++)
            {
                Task.Factory.StartNew(() => WorkerMethod(arr[i])); // IndexOutOfRangeException: i==2!!!
            }
        }

        void WorkerMethod(int i)
        {
        }
    }
}

---

似乎 i++ 在循环迭代完成之前又执行了一次。为什么会出现 IndexOutOfRangeException？

Answer 1

使用foreach 不会抛出：

foreach (var i in arr)
{
  Task.Factory.StartNew(() => WorkerMethod(i));
}

但它也不起作用：

101
101

它使用数组中的最后一个条目执行WorkerMethod。为什么在其他答案中得到了很好的解释。

这确实工作：

Parallel.ForEach(arr, 
                 item => Task.Factory.StartNew(() => WorkerMethod(item))
                 );

注意

这实际上是我第一次亲身体验System.Threading.Tasks。我发现这个问题，我天真的答案，尤其是其他一些对我个人学习经验有用的答案。我会在这里留下我的答案，因为它可能对其他人有用。

Answer 2

您正在关闭循环变量。当需要调用WorkerMethod 时，i 的值可以是 2，而不是 0 或 1。

当您使用闭包时，重要的是要了解您现在使用的不是变量的值，而是变量本身。因此，如果您像这样在循环中创建 lambda：

for(int i = 0; i < 2; i++) {
    actions[i] = () => { Console.WriteLine(i) };
}

稍后执行动作，它们都会打印“2”，因为这就是i的值。

在循环中引入局部变量将解决您的问题：

for (int i = 0; i < 2; i++)
{
    int index = i;
    Task.Factory.StartNew(() => WorkerMethod(arr[index])); 
}

这是尝试Resharper 的又一理由 - 它提供了许多警告，可帮助您及早发现此类错误。 “关闭循环变量”就在其中plug>

Answer 3

原因是您在并行任务中使用了循环变量。因为任务可以并发执行，所以循环变量的值可能与启动任务时的值不同。

您在循环中启动了任务。当任务开始查询循环变量时，循环已经结束，因为变量 i 现在超出了停止点。

即：

• i = 2，循环退出。
• 任务使用变量 i（现在是 2）

您应该使用 Parallel.For 来并行执行循环体。这里是an example of how to use Parallel.For

另外，如果您想保持当前结构，可以将 i 的副本复制到循环局部变量中，并且循环局部副本会将其值保留到并行任务中。

例如

for (int i = 0; i < 2; i++)
{
  int localIndex = i;
  Task.Factory.StartNew(() => WorkerMethod(arr[localIndex])); 
}