スレッドを使用する - コレクションに追加

Question

List<int> data=new List<int>(); 
foreach(int id in ids){ 
    var myThread=new Thread(new ThreadStart(Work)); 
    myThread.Start(id); 
} 


Work(){ 
} 

メソッド受信したIDに対して処理を行い、その結果をデータリストに追加しますか？各スレッドからコレクションにデータを追加するにはどうすればよいですか？私のコードはどのように見えますか？ありがとう

Answer 1

.NET 4を使用している場合は、代わりにParallel Extensionsを使用することを強くお勧めします。例えば：

Workである

var list = ids.AsParallel() 
       .Select(Work) 
       .ToList(); 

：

public int Work(int id) 
{ 
    ... 
} 

それが適切idを受信できるようにします。

var list = ids.AsParallel() 
       .Select(id => Work(id)) 
       .ToList(); 

いずれかの方法、これはあなたが本当に必要以上のスレッドを作成しないように、そしてあなたなしで物事のスレッドの安全性の側面に対処します：あなたはメソッド変換に熱心でないなら、あなたはラムダ式を追加することができます自分でロックを管理する必要があります。

Answer 2

スレッドからデータを（コールバックを使用して）渡したり取得したりすることができます。 MSDN articleを参照してください。

例：すべての

public class SomeClass 
    { 
     public static List<int> data = new List<int>(); 
     public static readonly object obj = new object(); 

     public void SomeMethod(int[] ids) 
     { 
      foreach (int id in ids) 
      { 
       Work w = new Work(); 
       w.Data = id; 
       w.callback = ResultCallback; 
       var myThread = new Thread(new ThreadStart(w.DoWork)); 
       myThread.Start(); 
      } 
     } 

     public static void ResultCallback(int d) 
     {   
      lock (obj) 
      {   
       data.Add(d); 
      } 
     } 

    } 

    public delegate void ExampleCallback(int data); 
    class Work 
    { 
     public int Data { get; set; } 
     public ExampleCallback callback; 

     public void DoWork() 
     {     
      Console.WriteLine("Instance thread procedure. Data={0}", Data); 
      if (callback != null) 
       callback(Data); 
     } 

    } 

Answer 3

まず、あなたはロックを使用してマルチスレッドアクセスを保護する必要があります。次に、パラメータをスレッドに渡す必要があります（または、ローカル変数を取得できるlambdaを使用します。ループ変数を取得すると、ループ中に値が変更されるため、ローカルコピーが必要です）。

object collectionLock = new object(); 
List<int> data = new List<int>(); 

foreach (int id in ids) 
{ 
    Thread t = new Thread(Worker); 
    t.Start(id); 
} 

void Worker(object o) 
{ 
    int id = (int)o; 
    lock(collectionLock) 
    { 
     data.Add(id); 
    } 
}