Wie sammle ich Rückgabewerte von Parallel.ForEach?

Nenne ich eine langsame webservice parallel. Die Dinge waren großartig, bis ich erkannte, dass ich brauchen, um einige Informationen vom Dienst zurück. Aber ich sehe nicht, wo man die Werte zurück. Ich kann nicht in die Datenbank schreiben, HttpContext.Aktuelle zu sein scheint null innerhalb einer Methode aufgerufen, über die Parallel.ForEach

Unten ist ein Beispiel-Programm (in deinem Geist, bitte stellen Sie sich eine langsame web service anstelle der string-Verkettung)

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;
        }
    }

}
Kommentar zu dem Problem
Eine andere überladung von Parallel.ForEach kann das sein, was Sie wollen: msdn.microsoft.com/en-us/library/dd991486.aspx Kommentarautor: Austin Salonen
Leider ist nicht wirklich etwas, das Sie tun können, dass. Parallel.Foreach() nur noch nicht gebaut war zum verfolgen gibt. Ich würde jedoch empfehlen die Verwendung von ref - Parameter im AddB Funktion. Das könnte es tun. Kommentarautor: Phillip Schmidt
@PhillipSchmidt: Nicht mit der überlastung in dem Beispiel verwendet sowieso... Kommentarautor: Austin Salonen
@AustinSalonen, Was eine weitere überladung, die funktionieren würde? Ich argumentiere nicht, ich war einfach nicht bewusst, dass alles tun würde, was er will. Kommentarautor: Phillip Schmidt
@PhillipSchmidt Den link in meinem ersten Kommentar explizit behandelt, eine Func<...> statt Action - <...> Kommentarautor: Austin Salonen

InformationsquelleAutor der Frage MatthewMartin | 2012-09-26

  1. 47

    Haben Sie verworfen es hier.

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

    Möchten Sie wahrscheinlich so etwas wie,

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

    Wenn Sie möchten, irgendeine Art von Auflistung am Ende dieser, sollten Sie verwenden eine der Sammlungen unter System.Collections.Concurrent wie ConcurrentBag

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

//Do something with result

    InformationsquelleAutor der Antwort M Afifi

  2. 14

    Ihr können überlegen AsParallel Erweiterung Methode der IEnumerable es kümmert sich um die Parallelität für Sie und sammeln Sie die Ergebnisse.


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

    Synchronisation (z.B. Schlösser oder concurrent collections, sperren) sind in der Regel Engpass von konkurrierenden algorithmen. Das beste ist das vermeiden von synchronisation so viel wie möglich. Ich vermute, dass AsParallel verwendet etwas schlauer, wie wenn man alle hergestellten Gegenstände einzigen thread in einem lokalen non-concurrent collection und dann kombinieren Sie diese am Ende.

    InformationsquelleAutor der Antwort Steves

  3. 11

    Nicht verwenden ConcurrentBag um Ergebnisse zu sammeln, wie es ist extrem langsam.
    Verwenden Sie lokale Sperre statt.

    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

    InformationsquelleAutor der Antwort Minh Nguyen

  4. 2

    Wie wäre es mit etwas wie dieses:

    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;
    }
}

    Glaube ich, dass die Sperr-oder Auger-Objekte ist nicht erforderlich, es sei denn, Sie müssen die Ergebnisse mit einer anderen interagieren kann (wie Sie die Berechnung einer Summe oder Kombination aller Worte). In diesem Fall ist ForEach ordentlich bricht Ihrer ursprünglichen Liste und Hände jeder thread sein eigenes Objekt, das Sie manipulieren können, alles, was Sie will, ohne sich Gedanken über stören die anderen threads.

    InformationsquelleAutor der Antwort MichaC

  5. 1

    Dieser scheint schnell, sicher und einfach:

        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;
    }

    InformationsquelleAutor der Antwort Overlord Zurg

Schreibe einen Kommentar