.Net 4.0中的任务[重复]

Question

我正在尝试使用 .Net 4.0 c# 中的 Task 进行并行编程。

我的程序的输出有点混乱。

 class Program
    {
        static void Main(string[] args)
        {

            List<Task> lstTasks =  new List<Task>();
            for (int i = 0; i < 5; i++)
            {
                Task tsk = Task.Factory.StartNew(() => DoSomething(i.ToString()));
                lstTasks.Add(tsk);
            }

            Task.WaitAll(lstTasks.ToArray());
            Console.WriteLine("Done");
            Console.ReadLine();
        }

        static void DoSomething(string tasKname)
        {
            Console.WriteLine(tasKname);
            System.Threading.Thread.Sleep(10000);
        }
    }

输出是

5
5
5
5
5
Done.

我期待。

0
1
2
3
4
Done.

我哪里出错了？

Answer 1

您在定义函数() => DoSomething(i.ToString()) 时创建了closure。

闭包是一个匿名函数/lamdba，它引用在创建闭包的方法中定义的一些变量。在你的情况下，这是变量i。

当这个函数被执行时，它将使用i的当前值，而不是i在你创建它时的值。

您必须注意，调用Task.Factory.StartNew 不会立即开始执行任务。在您的情况下，任务在 for 循环之后开始执行，因此 i 的值为 5。

要获得您期望的结果，请在循环中使用一个单独的变量来存储i 的当前值。

for (int i = 0; i < 5; i++)
{
    int k = i;
    Task tsk = Task.Factory.StartNew(() => DoSomething(k.ToString()));
    lstTasks.Add(tsk);
}

不过，您不应期望结果按任何特定顺序排列。

Answer 2

您正在访问一个在循环中发生变化的变量。从本质上讲，您的foreach 运行得非常快，当DoSomething 运行时，i 是 5。试试这个：

for (int i = 0; i < 5; i++)
{
    Task tsk = Task.Factory.StartNew(() => DoSomething(i.ToString()));
    lstTasks.Add(tsk);
    Thread.Sleep(50);
}

您应该会在控制台中看到预期的输出。

---

你说I'm expecting 0 1 2 3 4。但你不应该。任务最重要的方面是您不知道它们何时会完成。例如，当我更改您的代码以使用 Parallel.Foreach() 时：

Parallel.ForEach(Enumerable.Range(0, 5), i =>
{
    Task tsk = Task.Factory.StartNew(() => DoSomething(i.ToString()));
    lstTasks.Add(tsk);
});

我得到了预期的数字，从 0 到 4，但每次我运行代码时都是随机顺序，因为我们使用的是 Tasks，它们都彼此独立运行。