Parallel.ForEachから戻り値を収集するにはどうすればよいですか？

Question

私は、遅いウェブサービスを並行して呼びます。私はサービスから何らかの情報を得る必要があることがわかって初めて、物事は素晴らしかったです。しかし、どこに値を戻すかわかりません。私はデータベースに書き込むことができません、HttpContext.Currentは、Parallel.ForEachを使用して呼び出されたメソッド内でヌルのように見えます

以下は、サンプルプログラムです（あなたの考えでは、文字列連結）

using System; 
using System.Threading.Tasks; 

class Program 
{ 
    static void Main(string[] args) 
    { 
     WordMaker m = new WordMaker(); 
     m.MakeIt(); 
    } 
    public class WordMaker 
    { 
     public void MakeIt() 
     { 
      string[] words = { "ack", "ook" }; 
      ParallelLoopResult result = Parallel.ForEach(words, word => AddB(word)); 
      Console.WriteLine("Where did my results go?"); 
      Console.ReadKey(); 
     } 
     public string AddB(string word) 
     { 
      return "b" + word; 
     } 
    } 

} 

Answer 1

あなたはここでそれを破棄しました。あなたは、おそらくのような何かをしたい

ParallelLoopResult result = Parallel.ForEach(words, word => AddB(word)); 

、あなたがこのの終わりにコレクションのいくつかの並べ替えをしたい場合

ParallelLoopResult result = Parallel.ForEach(words, word => 
{ 
    string result = AddB(word); 
    // do something with result 
}); 

、ConcurrentBag

var resultCollection = new ConcurrentBag<string>(); 
ParallelLoopResult result = Parallel.ForEach(words, word => 
{ 
    resultCollectin.Add(AddB(word)); 
}); 

// Do something with result 

Answer 2

のように、 System.Collections.Concurrent下のコレクションの一つを使用することを検討してください

ConcurrentBagを使用して極端に遅い結果を収集しないでください。 代わりにローカルロックを使用してください。

どのようにこのような何かについて

var resultCollection = new List<string>(); 
object localLockObject = new object(); 

Parallel.ForEach<string, List<string>>(
     words, 
    () => { return new List<string>(); }, 
     (word, state, localList) => 
     { 
     localList.Add(AddB(word)); 
     return localList; 
     }, 
     (finalResult) => { lock (localLockObject) resultCollection.AddRange(finalResult); } 
); 

// Do something with resultCollection here 

Answer 3

：私はあなたが和を計算または組み合わせたような結果が互いに（と対話する必要がある場合を除き、ロックまたは同時のオブジェクトが必要ではないと信じて

public class WordContainer 
{ 
    public WordContainer(string word) 
    { 
     Word = word; 
    } 

    public string Word { get; private set; } 
    public string Result { get; set; } 
} 

public class WordMaker 
{ 
    public void MakeIt() 
    { 
     string[] words = { "ack", "ook" }; 
     List<WordContainer> containers = words.Select(w => new WordContainer(w)).ToList(); 

     Parallel.ForEach(containers, AddB); 

     //containers.ForEach(c => Console.WriteLine(c.Result)); 
     foreach (var container in containers) 
     { 
      Console.WriteLine(container.Result); 
     } 

     Console.ReadKey(); 
    } 

    public void AddB(WordContainer container) 
    { 
     container.Result = "b" + container.Word; 
    } 
} 

すべての言葉）。この場合、ForEachは元のリストをきれいに分割し、各スレッドに独自のオブジェクトを渡して、他のスレッドとの干渉を心配することなく、必要なものすべてを操作できるようにします。

Answer 4

AsParallel拡張メソッドIEnumerableを使用することを検討しても、それはあなたのために並行処理を行い、結果を収集します。

words.AsParallel().Select(AddB).ToArray()

同期（例えば、ロックまたはロックを使用する同時コレクション）は、通常、並行アルゴリズムのボトルネックです。最高の同期はできるだけ避けることです。私は、AsParallelが、単一のスレッドで生成されたすべてのアイテムをローカルの非並行コレクションに入れ、最後にこれらを結合するような、よりスマートなものを使用していると推測しています。

Answer 5

これは、安全で速く、簡単なようだ：

public string[] MakeIt() { 
     string[] words = { "ack", "ook" }; 
     string[] results = new string[words.Length]; 
     ParallelLoopResult result = 
      Parallel.For(0, words.Length, i => results[i] = AddB(words[i])); 
     return results; 
    }