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

Reedの回答（+1）に同意します。

.NET 4の場合は、このクラスの問題を解決するためにTask Parallel Libraryを参照することをお勧めします。具体的には、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); 
     }); 

} 

....