¿Por qué Parallel.ForEach no está ejecutando varios subprocesos?

Question

Hoy probé hacer alguna optimización a la declaración foreach, que funciona en XDocument.

Antes de optimización:

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

Después de la optimización:

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

vi que en .NET Parallel.ForEach(...) abrió sólo un hilo! Como resultado, el intervalo de tiempo de Parallel fue mayor que el estándar foreach.

¿Por qué crees que .NET solo abrió 1 hilo? Debido al bloqueo de archivo? Gracias

Answer 1

Es por diseño que Parallel.ForEach puede utilizar un menor número de hilos que el solicitado para lograr un mejor rendimiento. De acuerdo con MSDN [link]:

Por defecto, los métodos y Parallel.ForEach Parallel.For puede utilizar un número variable de tareas. Es por eso que, por ejemplo, la clase ParallelOptions tiene una propiedad MaxDegreeOfParallelism en lugar de una propiedad "MinDegreeOfParallelism". La idea es que el sistema puede usar menos hilos de los solicitados para procesar un bucle.

El grupo de subprocesos de .NET se adapta dinámicamente a cargas de trabajo cambiantes al permitir que el número de subprocesos de trabajo para tareas paralelas cambie con el tiempo. En tiempo de ejecución, el sistema observa si aumentar el número de subprocesos mejora o degrada el rendimiento general y ajusta el número de subprocesos de trabajo en consecuencia.

Answer 2

No siempre el camino paralelo es más rápido que la "antigua usanza" http://social.msdn.microsoft.com/Forums/en-US/parallelextensions/thread/c860cf3f-f7a6-46b5-8a07-ca2f413258dd

Answer 3

Sí exactamente, Document.Load(...)locks the file y debido a los recursos contención entre hilos, TPL es incapaz de utilizar el poder de múltiples hilos. Intente cargar el XML en un Stream y luego use Parallel.For(...).

Answer 4

¿Tiene un solo procesador? TPL puede limitar el número de hilos a uno en este caso. Lo mismo puede suceder si la colección es muy pequeña. Pruebe una colección más grande. Consulte this answer para obtener más información sobre cómo se determina el grado de paralelismo.

Answer 5

utilizar de esta manera:

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

Answer 6

De la descripción del problema, no hay nada que explique por qué el TPL no está generando más hilos.

No hay evidencia en la pregunta que sea siquiera el problema. Eso se puede solucionar con bastante facilidad: puede registrar la id. Del subproceso, antes de ingresar al bucle, y como lo primero que hace dentro del ciclo.

Si siempre es el mismo número, es el TPL que falla al generar subprocesos. A continuación, debe probar diferentes versiones de su código y qué cambio activa el TPL para serializar todo. Una razón podría ser si hay una pequeña cantidad de elementos en su lista.El TPL divide su colección, y si tiene solo algunos elementos, puede terminar con un solo lote. Este comportamiento es configurable por cierto.

Podría estar inadvertidamente teniendo un bloqueo en el circuito, entonces verá muchos números diferentes, pero no hay aceleración. Luego, simplifique el código hasta que el problema desaparezca.