bezpieczeństwo Temat zwrotu plonu z Parallel.ForEach()

Question

Rozważmy następujący przykładowy kod, który tworzy enumerable zbiór liczb całkowitych i przetwarza je równolegle:

using System.Collections.Generic; 
using System.Threading.Tasks; 

public class Program 
{ 
    public static void Main() 
    { 
     Parallel.ForEach(CreateItems(100), item => ProcessItem(item)); 
    } 

    private static IEnumerable<int> CreateItems(int count) 
    { 
     for (int i = 0; i < count; i++) 
     { 
      yield return i; 
     } 
    } 

    private static void ProcessItem(int item) 
    { 
     // Do something 
    } 
} 

To jest zagwarantowane, że wątków roboczych generowane przez Parallel.ForEach() każdy dostanie inny element lub jest jakiś mechanizm blokujący wokół inkrementacji i zwrotu z i wymagane?

Answer 1

Parallel.ForEach<TSource>, gdy TSource jest IEnumerable<T> tworzy partycjonowania dla IEnumerable<T> który zawiera własną wewnętrzny mechanizm blokujący, więc nie trzeba do wykonania jakiegokolwiek wątku bezpieczeństwa w swoim iteracyjnej.

Ilekroć wątek pracownik prosi o kawałek pozycji, partycjoner stworzy wewnętrznego wyliczający, który:

1. nabywa blokady współdzielonej
2. iteracji źródła (skąd został lewej) w celu pobrania fragmentu pozycji, zapisanie elementów w prywatnej macierzy powoduje zwolnienie blokady, aby inne żądania fragmentów mogły zostać spełnione.
3. służy do wątku roboczego z jego prywatnej tablicy.

Jak widać, przebieg przez IEnumerable<T> dla celów partycjonowania jest sekwencyjny (dostęp przez współdzieloną blokadę), a partycje są przetwarzane równolegle.

Answer 2

TPL i PLINQ wykorzystują koncepcję podkładek.

Partycjoner to typ dziedziczyjący Partitioner<TSource> i służy do dzielenia sekwencji źródłowej na części numeryczne (lub partycje). Wbudowane partycje zostały zaprojektowane tak, aby podzielić sekwencję źródłową na partycje nienapiętrzające.