Perché non Parallel.ForEach esegue più thread?

Question

Oggi ho provato a fare qualche ottimizzazione sull'istruzione foreach, che funziona su XDocument.

Prima di ottimizzazione:

foreach (XElement elem in xDoc.Descendants("APSEvent").ToList()) 
{ 
    //some operations 
} 

Dopo l'ottimizzazione:

Parallel.ForEach(xDoc.Descendants("APSEvent").ToList(), elem => 
{ 
    //same operations 
}); 

ho visto che .NET in Parallel.ForEach(...) ha aperto solo un thread! Di conseguenza, il periodo di Parallel era più grande dello standard foreach.

Per quale motivo .NET ha aperto solo 1 thread? A causa del blocco del file? Grazie

Answer 1

E 'di design che Parallel.ForEach può utilizzare un minor numero di thread di richiesta per ottenere prestazioni migliori. Secondo MSDN [link]:

Per impostazione predefinita, i metodi e Parallel.ForEach Parallel.For può utilizzare un numero variabile di compiti. Ecco perché, per esempio, la classe ParallelOptions ha una proprietà MaxDegreeOfParallelism invece di una proprietà "MinDegreeOfParallelism". L'idea è che il sistema possa utilizzare meno thread di quanto richiesto per elaborare un ciclo.

Il pool di thread .NET si adatta in modo dinamico ai carichi di lavoro in evoluzione consentendo al numero di thread di lavoro per le attività parallele di cambiare nel tempo. In fase di esecuzione, il sistema osserva se l'aumento del numero di thread migliora o riduce il throughput complessivo e regola di conseguenza il numero di thread di lavoro.

Answer 2

Non sempre la strada parallela è più veloce rispetto alla "vecchia maniera" http://social.msdn.microsoft.com/Forums/en-US/parallelextensions/thread/c860cf3f-f7a6-46b5-8a07-ca2f413258dd

Answer 3

Sì, esattamente, Document.Load(...)locks the file e grazie a risorsa contesa tra i thread, TPL è in grado di utilizzare la potenza di più thread. Prova a caricare l'XML in un Stream e quindi usa Parallel.For(...).

Answer 4

Ti capita di avere un singolo processore? In questo caso, il TPL potrebbe limitare il numero di thread a uno. La stessa cosa potrebbe accadere se la collezione è molto piccola. Prova una collezione più grande. Vedere this answer per ulteriori dettagli su come viene determinato il grado di parallelismo.

Answer 5

uso in questo modo:

int ParallelThreads = 10; 
Parallel.ForEach(xDoc.Descendants("APSEvent").ToList(), new ParallelOptions() { MaxDegreeOfParallelism = ParallelThreads }, (myXDOC, i, j) => 
{ 
//do whatever you want here 
}); 

Answer 6

Dalla descrizione del problema, non c'è nulla che spieghi perché il TPL non stia generando più thread.

Non c'è alcuna prova nella domanda che sia anche il problema. Questo può essere risolto abbastanza facilmente: puoi inserire l'id del thread, prima di entrare nel ciclo, e come prima cosa fai nel loop.

Se è sempre lo stesso numero, è il TPL che non riesce a generare i thread. Dovresti quindi provare diverse versioni del tuo codice e quale modifica attiva la TPL per serializzare tutto. Una ragione potrebbe essere se ci sono un piccolo numero di elementi nella tua lista.La TPL partiziona la tua raccolta e, se hai solo pochi elementi, potresti finire con un solo batch. Questo comportamento è configurabile a proposito.

Potrebbe essere che inavvertitamente si fa il blocco del ciclo, quindi vedrete molti numeri diversi, ma nessuna accelerazione. Quindi, semplifica il codice fino a quando il problema non scompare.