sicurezza Discussione di rendimento rendimento con Parallel.ForEach()

Question

Si consideri il seguente esempio di codice, che crea una collezione numerabile di numeri interi e lo elabora in parallelo:

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

E 'garantito che i thread di lavoro generati da Parallel.ForEach() Ognuno di essi ha un oggetto diverso o un meccanismo di blocco attorno all'incremento e alla restituzione di i richiesto?

Answer 1

Parallel.ForEach<TSource>, quando TSource è un IEnumerable<T>, crea un partizionamento per il IEnumerable<T> che include la propria meccanismo di bloccaggio interno, quindi non c'è bisogno di realizzare qualsiasi thread-sicurezza nella vostra iteratore.

Ogni volta che un thread di lavoro richiede un pezzo di voci, il partizionamento sarà creare un enumeratore interna, che:

1. acquisisce un blocco condiviso
2. itera attraverso la sorgente (da dove è stato lasciato di) per recuperare il blocco di elementi, salvando gli elementi in un array privato
3. rilascia il blocco in modo che altre richieste di blocco possano essere soddisfatte.
4. serve il thread di lavoro dal proprio array privato.

Come si vede, la corsa attraverso la IEnumerable<T> ai fini di partizionamento è sequenziale (accessibile tramite un blocco condiviso), e le partizioni vengono elaborati in parallelo.

Answer 2

TPL e PLINQ utilizzano il concetto di divisori .

Il partizionatore è un tipo che eredita Partitioner<TSource> e serve per suddividere la sequenza sorgente in parti (o partizioni) di numeri. I partizionatori integrati sono stati progettati per suddividere la sequenza sorgente in partizioni non sovrapposte.