开始在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(); 
    } 

有关详细信息，我建议你阅读关于这个确切的主题埃里克利珀的帖子：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

同意里德的回答（+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); 
     }); 

} 

虽然没有测试....