¿Forma fácil de procesar la cola con N hilos en C#?

Question

Tengo una lista de números de cuenta. Número de cuenta de Foreach Necesito llamar al método ProcessAccount. Habrá aproximadamente 150,000 cuentas que deben procesarse y cada cuenta puede tardar entre .5 y 2 segundos en procesarse.

Me gustaría configurar el enhebrado de alguna manera para poder procesar 4 cuentas a la vez, por ejemplo.

¿Hay un patrón simple que pueda usar para esto?

Lo que me gustaría hacer es iniciar 4 subprocesos procesando las primeras 4 cuentas, y luego, cuando termine cada subproceso, iniciar otro subproceso con la siguiente cuenta hasta que todas las cuentas hayan sido procesadas.

Answer 1

Esto es fácil de manejar con TPL (Task Parallel Library). Se vería algo así como

ParallelOptions options = new ParallelOptions() { MaxDegreeOfParallelism = 4 }; 
Parallel.ForEach(accounts, options, a => 
{ 
    ProcessAccount(a); 
}); 

http://msdn.microsoft.com/en-us/library/dd782721.aspx

Tenga en cuenta que el TPL podría decidir ejecutar menos de 4 hilos concurrentes, pero no se ejecutará más de 4 basado en las opciones especificadas. Podría hacer eso, por ejemplo, si determina que la lamda proporcionada (que llama a ProcessAccount) está unida a la CPU y que hay menos de 4 núcleos de CPU en el sistema. Generalmente, especialmente en .NET 4.5, el TPL toma muy buenas decisiones sobre el número de subprocesos que se utilizarán.

Como @Servy notas en los comentarios, a menos que tenga una razón muy específica para limitar el código a 4 hilos, lo mejor es dejar que TPL sepa cuántos hilos usar por sí solo. De esta forma, si el mismo código se ejecuta en un procesador de 128 núcleos en el año 2018, mucho después de que pase a otras cosas, es gratis usar los 128 núcleos).

Answer 2

Uso PLINQ:

var accounts = //some 150,000 account numbers 
accounts.AsParallel().ForAll(ProcessAccount); 

o, si se requieren otros argumentos, utilice una expresión lambda:

accounts.AsParallel().ForAll(account => ProcessAccount(account, argument2, argument3));