在 foreach 循环中启动一个新线程

Question

我有一个对象列表，我想遍历该列表并启动一个新线程，传入当前对象。

我已经写了一个我认为应该这样做的示例，但它不起作用。具体来说，似乎线程在每次迭代中都被覆盖了。但这对我来说真的没有意义，因为我每次都在创建一个新的 Thread 对象。

这是我写的测试代码

class Program
{
    static void Main(string[] args)
    {
        TestClass t = new TestClass();
        t.ThreadingMethod();
    }
}

class TestClass
{
    public void ThreadingMethod()
    {
        var myList = new List<MyClass> { new MyClass("test1"), new MyClass("test2") };

        foreach(MyClass myObj in myList)
        {
            Thread myThread = new Thread(() => this.MyMethod(myObj));
            myThread.Start();
        }
    }

    public void MyMethod(MyClass myObj) { Console.WriteLine(myObj.prop1); }
}

class MyClass
{
    public string prop1 { get; set; }

    public MyClass(string input) { this.prop1 = input; }
}

我机器上的输出是

test2
test2

但我预计会是这样

test1
test2

我尝试将线程线更改为

ThreadPool.QueueUserWorkItem(x => this.MyMethod(myObj));

但是没有线程启动。

我想我只是对线程应该如何工作有一个误解。有人可以指出我正确的方向并告诉我我做错了什么吗？

Answer 1

这是因为您在错误的范围内关闭了一个变量。这里的解决方案是在你的 foreach 循环中使用一个临时的：

    foreach(MyClass myObj in myList)
    {
        MyClass tmp = myObj; // Make temporary
        Thread myThread = new Thread(() => this.MyMethod(tmp));
        myThread.Start();
    }

有关详细信息，我建议阅读 Eric Lippert 关于这个确切主题的帖子：Closing over the loop variable considered harmful

Answer 2

问题在于您使用的是闭包内对象的最新值。因此，线程的每次调用都在查看相同的值。要解决这个问题，请将值复制到局部变量中：

foreach(MyClass myObj in myList)
{
    MyClass localCopy = myObj;
    Thread myThread = new Thread(() => this.MyMethod(localCopy));
    myThread.Start();
}

Answer 3

同意 Reed 的回答 (+1)。

我要补充一点，如果您使用的是 .NET 4，您可能需要查看任务并行库来解决此类问题。针对这种情况，请查看Parallel.ForEach()。

Answer 4

如果顺序无关紧要，那就去吧

Parallel.ForEach(myList, obj => this.MyMethod(obj) );

Write a Simple Parallel.ForEach Loop

Answer 5

我更喜欢这种方式：

public void ThreadingMethod()
{
    var myList = new List<MyClass> { new MyClass("test1"), new MyClass("test2") };


Parallel.ForEach(myList, new ParallelOptions() { MaxDegreeOfParallelism = 100 },
         (myObj, i, j) =>
         {
             MyMethod(myObj);
         });

}

虽然没有测试....