パラレルforeachのカウント

Question

私の質問はParallel Foreach Race Condition

にたくさん似ていますが、それは非常に明確に答え、それは私がのために、それぞれには、一定の基準を満たしているオブジェクトカウントする必要があるという意味で異なっていませんでした。そうであれば、それをリストに追加する必要があります。

そうだから、明らかにこのリストは、それぞれの通常の私は、スレッドロックか何かのように、同期してMetCriteriaオブジェクトを保持するためにいくつかの方法が必要となるため、すべての値が含まれていません。この

List<int> MetCriteria = new List<int>(); 
Parallel.ForEach(dt.AsEnumerable(), (entry,state) => { 

    if (Convert.ToInt32(entry["Time"]) > 100)//in miliseconds 
    MetCriteria.add(Convert.ToInt32(entry["EntryID"]); 
}); 

のようなものしかし、私は

Answer 1

あなたはConcurrentBagのようなスレッドセーフなコレクションを使用することができますしてください。この

任意のヘルプを行う方法がわからないと思います。

var MetCriteria = new ConcurrentBag<int>(); 
Parallel.ForEach(dt.AsEnumerable(), (entry,state) => { 

    if (Convert.ToInt32(entry["Time"]) > 100)//in miliseconds 
    MetCriteria.add(Convert.ToInt32(entry["EntryID"]); 
}); 

Answer 2

確かにあなたのリストを脅威に耐えるようにロックすることができます。しかし、私はDovydas Sopaのようなスレッドセーフなコレクションを使用します。

List<int> MetCriteria = new List<int>(); 
Parallel.ForEach(dt.AsEnumerable(), (entry, state) => 
{ 
    if (Convert.ToInt32(entry["Time"]) > 100)//in miliseconds 
    { 
     lock (MetCriteria) 
     { 
      MetCriteria.Add(Convert.ToInt32(entry["EntryID"])); 
     } 

    } 
});