Wie, um eine IEnumerable-Methode parallel-Methode

Nach diesem post, Ich will parallelisieren dieser Methode :

    public IEnumerable<string> GetAllLogs(IEnumerable<IComputer> computers)
    {
        foreach (var cpt in computers)
        {
            foreach (var log in cpt.GetLogs())
            {
                yield return log;
            }
        }
    }

Möchte ich die Methode "geben gibt" ist ein Protokoll, wenn man von der Methode GetLogs fertig ist. Wenn ich 4 Computer gibt :

  • Computer 01 : "a", "b", "c", "d", "e"
  • Computer 02 : "1", "2", "3", "4", "5"
  • Computer-03 : "alpha", "beta", "gamma", "delta", "epsilon"
  • Computer 04 : "I", "II", "III", "IV", "V"

Mit der "sequenzielle Methode", die Ausgabe ist :

a
b
c
d
e
1
2
3
4
5
alpha
beta
gamma
delta
epsilon
I
II
III
IV
V

Und der Methoden läuft in 20 Sekunden. es ist ein Thread.Sleep(1000) im GetLogs Methode.

Möchte ich die Ausgabe sieht wie folgt aus :

III
a
4
gamma
b
c
IV
5
d
II
beta
e
1
2
delta
alpha
3
epsilon
I

und verläuft in wenigen Sekunden.

Möchte ich die Methoden liefert ein IEnumerable

InformationsquelleAutor Florian | 2011-11-24
  1. 16

    Dies ist, was Sie brauchen: 

    public IEnumerable<string> GetAllLogsParallel(IEnumerable<IComputer> computers)
{
    return computers
        .AsParallel()
        .SelectMany(cpt => cpt.GetLogs());
}

    Wenn Sie möchten, um die Bearbeitung von 4 computer-s zur gleichen Zeit, können Sie stellen Sie den Grad der Parallelität wie diese:

    public IEnumerable<string> GetAllLogsParallel(IEnumerable<IComputer> computers)
{
    return computers
        .AsParallel()
        .WithDegreeOfParallelism(4)
        .SelectMany(cpt => cpt.GetLogs());
}

    Folgenden ist eine vereinfachte Erklärung gerade für das Verständnis.
    Um zu lernen mehr über, besuchen Sie einfach PLINQ (Parallel LINQ) auf der MSDN-Website.

    Gut, .AsParallel() teilt das computers enumerable in 4 Teile und beginnt, die 4 threads gleichzeitig. Jeder thread führt cpt.GetLogs() für jeden computer. Das Ergebnis ist IEnumerable<IEnumerable<string>> - aufzählbaren von enumerables. SelectMany() wird verwendet, um glätten diese Liste durch die Verkettung innerer enumerables und die Beseitigung der äußeren. Ergebnisse zusammengeführt werden automatisch zurück in den Haupt-thread in der Reihenfolge Ihrer Ankunft.

    • Ja, es funktioniert... Alle GetLogs() scheint zu beenden, in der gleichen Zeit. (5 Sekunden env.) Ja ich brauche Erklärungen, wenn möglich :$
    • Das ist richtig, aber Sie warten, bevor Sie zu keinem Ergebnis. ( Als kleine Randbemerkung )
    • Nein, Sie warten nicht für jeden anderen.
    • Natürlich tun Sie das, nicht, bei der Ausführung der Aufgaben, aber die Methode gibt alle Werte auf einmal und nicht mit einem Verhalten, das gegeben ist durch yield.
    • Der Rückgabewert der Methode ist ein enumerable nicht die Werte, die von GetLogs. Die Methode gibt sofort einen Wert zurück. Die Werte werden abgefragt und zurückgegeben Durchlaufen werden, sobald Sie Durchlaufen es.
    • Gut zu wissen, ich dachte, er parallizes die GetLogs und kehrt nach alles Lesen.
    • es druckt alle auf einmal. ist dieses erwartete Verhalten ?
    • Druck auf einmal anders ist das Verhalten von Ertrag dieses Beispiel nicht arbeiten. Es ist gültig, wenn Sie wollen, dass die ganze IEnumerable zurück. Ausbeute syntax impliziert der Rückkehr ein Element zu einem Zeitpunkt

    InformationsquelleAutor George Mamaladze
Schreibe einen Kommentar