ManualResetEventによる並列プログラミング

Question

List<string>の並列処理には1つの方法があります。残念ながら.NET 4+は使用できません。

しかし、私はこの方法を実行すると、iはいつも私が

X 0
×1
×2

を達成するために変更する必要が何items.Count

public static void ParallelForEachTest(List<string> items) 
{ 
    if (items != null && items.Count > 0) 
    { 
     List<ManualResetEvent> mEventList = new List<ManualResetEvent>(); 
     for (int i = 0; i < items.Count ; i++) 
     { 
      ManualResetEvent mEvent = new ManualResetEvent(false); 
      ThreadPool.QueueUserWorkItem((y) => 
      { 
       Console.WriteLine(items[i] + i); 
       mEvent.Set(); 
      }); 
      mEventList.Add(mEvent); 
     } 
     mEventList.ForEach(x => x.WaitOne()); 
    } 
} 

ですParallelForEachTest(new List<string>(){"x","x","x"});

Answer 1

Console.WriteLineが実行された時点で、ループは既に終了しており、ループ変数iの最終値はlist.Countです。

各タスクは、それに対応するインデックスを印刷持つためには、タスク自体にインデックス値を渡す必要があります：

ThreadPool.QueueUserWorkItem((y) => { ... }, i); 

2番目の引数はタスクたら、コールバックに渡される状態であり、が開始される。

また、クロージャを使用してタスク内から状態にアクセスしないようにしてください。タスク状態を使用してデータを転送する：

public static void ParallelForEachTest(List<string> items) 
{ 
    if (items != null && items.Count > 0) 
    { 
     List<ManualResetEvent> mEventList = new List<ManualResetEvent>(); 
     for (int i = 0; i < items.Count; i++) 
     { 
      ManualResetEvent mEvent = new ManualResetEvent(false); 
      ThreadPool.QueueUserWorkItem(
       (state) => 
       { 
        Tuple<string, int, ManualResetEvent> tuple = 
         (Tuple<string, int, ManualResetEvent>)state; 
        Console.WriteLine(tuple.Item1 + tuple.Item2); 
        tuple.Item3.Set(); 
       }, 
       Tuple.Create(items[i], i, mEvent)); 
      mEventList.Add(mEvent); 
     } 
     mEventList.ForEach(x => x.WaitOne()); 
    } 
}