Beibehaltung der Reihenfolge in PLINQ

In PLINQ besteht das Ziel darin, die Leistung zu maximieren und gleichzeitig die Korrektheit aufrechtzuerhalten. Eine Abfrage sollte so schnell wie möglich ausgeführt werden, aber dennoch die richtigen Ergebnisse erzielen. In einigen Fällen muss die Reihenfolge der Quellsequenz beibehalten werden; Die Sortierung kann jedoch rechenintensiv sein. Daher behält PLINQ standardmäßig nicht die Reihenfolge der Quellsequenz bei. In diesem Zusammenhang ähnelt PLINQ LINQ to SQL, steht jedoch im Gegensatz zu LINQ to Objects, das die Sortierung bewahrt.

Um das Standardverhalten außer Kraft zu setzen, können Sie die Reihenfolge beibehalten, indem Sie den AsOrdered Operator für die Quellsequenz verwenden. Sie können die Reihenfolgenerhaltung später in der Abfrage mithilfe der AsUnordered Methode deaktivieren. Bei beiden Methoden wird die Abfrage basierend auf den Heuristiken verarbeitet, die bestimmen, ob die Abfrage parallel oder sequenziell ausgeführt werden soll. Weitere Informationen finden Sie unter Understanding Speedup in PLINQ.

Das folgende Beispiel zeigt eine ungeordnete parallele Abfrage, die nach allen Elementen filtert, die einer Bedingung entsprechen, ohne die Ergebnisse auf irgendeine Weise zu ordnen.

var cityQuery =
    (from city in cities.AsParallel()
     where city.Population > 10000
     select city).Take(1000);

Dim cityQuery = From city In cities.AsParallel()
                Where city.Population > 10000
                Take (1000)

Diese Abfrage erzeugt nicht unbedingt die ersten 1000 Städte in der Quellsequenz, die die Bedingung erfüllen, sondern einige von 1000 Städten, die die Bedingung erfüllen. PLINQ-Abfrageoperatoren partitionieren die Quellsequenz in mehrere Untersequencen, die als gleichzeitige Aufgaben verarbeitet werden. Wenn die Erhaltung der Reihenfolge nicht angegeben ist, werden die Ergebnisse jeder Partition an die nächste Phase der Abfrage in einer beliebigen Reihenfolge übergeben. Außerdem kann eine Partition eine Teilmenge ihrer Ergebnisse liefern, bevor sie die verbleibenden Elemente weiter verarbeitet. Die resultierende Reihenfolge kann jedes Mal unterschiedlich sein. Die Anwendung kann dies nicht steuern, da sie davon abhängt, wie das Betriebssystem die Threads plant.

Im folgenden Beispiel wird das Standardverhalten überschrieben, indem der AsOrdered Operator in der Quellsequenz verwendet wird. Dadurch wird sichergestellt, dass die Take Methode die ersten 1000 Städte in der Quellsequenz zurückgibt, die die Bedingung erfüllen.

var orderedCities =
    (from city in cities.AsParallel().AsOrdered()
     where city.Population > 10000
     select city).Take(1000);

Dim orderedCities = From city In cities.AsParallel().AsOrdered()
                    Where city.Population > 10000
                    Take (1000)

Diese Abfrage wird jedoch wahrscheinlich nicht so schnell ausgeführt wie die ungeordnete Version, da sie die ursprüngliche Sortierung während der gesamten Partitionen nachverfolgen muss und zur Zusammenführungszeit sicherstellen muss, dass die Sortierung konsistent ist. Daher empfiehlt es sich, nur dann zu verwenden AsOrdered , wenn sie erforderlich ist, und nur für die Teile der Abfrage, für die sie erforderlich ist. Wenn die Beibehaltung der Reihenfolge nicht mehr notwendig ist, deaktivieren Sie diese mit AsUnordered. Im folgenden Beispiel wird dies erreicht, indem zwei Abfragen verfasst werden.

var orderedCities2 =
    (from city in cities.AsParallel().AsOrdered()
     where city.Population > 10000
     select city).Take(1000);

var finalResult =
    from city in orderedCities2.AsUnordered()
    join p in people.AsParallel()
    on city.Name equals p.CityName into details
    from c in details
    select new
    {
        city.Name,
        Pop = city.Population,
        c.Mayor
    };

foreach (var city in finalResult) { /*...*/ }

Dim orderedCities2 = From city In cities.AsParallel().AsOrdered()
                     Where city.Population > 10000
                     Select city
                     Take (1000)

Dim finalResult = From city In orderedCities2.AsUnordered()
                  Join p In people.AsParallel() On city.Name Equals p.CityName
                  Select New With {.Name = city.Name, .Pop = city.Population, .Mayor = city.Mayor}

For Each city In finalResult
    Console.WriteLine(city.Name & ":" & city.Pop & ":" & city.Mayor)
Next

Beachten Sie, dass PLINQ die Reihenfolge einer Sequenz beibehält, die von Reihenfolge erzwingenden Operatoren für den verbleibenden Teil der Abfrage erzeugt wird. Mit anderen Worten, Operatoren wie OrderBy und ThenBy werden behandelt, als ob ihnen ein Aufruf von AsOrdered folgen würde.

Abfrageoperatoren und Sortierung

Mit den folgenden Abfrageoperatoren wird die Reihenfolgeerhaltung in alle nachfolgenden Abfragevorgänge eingeführt, oder bis AsUnordered aufgerufen wird.

• OrderBy

• OrderByDescending

• ThenBy

• ThenByDescending

Die folgenden PLINQ-Abfrageoperatoren können in einigen Fällen geordnete Quellsequenzen erfordern, um korrekte Ergebnisse zu erzielen:

• Reverse

• SequenceEqual

• TakeWhile

• SkipWhile

• Zip

Einige PLINQ-Abfrageoperatoren verhalten sich je nachdem, ob ihre Quellsequenz sortiert oder ungeordnet ist. In der folgenden Tabelle sind diese Operatoren aufgeführt.

Ungeordnete Ergebnisse werden nicht aktiv neu angeordnet; sie haben einfach keine spezielle Sortierlogik angewendet. In einigen Fällen kann eine ungeordnete Abfrage die Reihenfolge der Quellsequenz beibehalten. Für Abfragen mit dem indizierten Select-Operator stellt PLINQ sicher, dass Elemente in aufsteigender Indexreihenfolge ausgegeben werden, jedoch wird nicht festgelegt, welcher Index welchem Element zugewiesen wird.

Siehe auch

• Parallel LINQ (PLINQ)
• parallele Programmierung