ForEach paralelo, y las colas

¿Es posible tener un paralelo para cada proceso de bucle los artículos en una cola de tal manera que:ForEach paralelo, y las colas

sólo elimina los objetos que se están procesando
se detiene hasta que se añaden nuevos elementos a la cola

EDIT: Esto es en lo que respecta a la funcionalidad Parallel.ForEach System.Threading.Tasks'

Fuente

2011-07-01 Anonymous

Salida a esta pregunta también: http://stackoverflow.com/questions/6308225/tpl-architectural-question –

nah de la respuesta para esa la pregunta es demasiado compleja. La Programación Reactiva es la solución. –

Suscríbase a la cola usando Reactive Extensions y ejecute cada elemento en una nueva tarea. No tendrá que bloquear ni esperar un nuevo artículo, ya que se insertará en su lambda de suscripción y su ejecución/procesamiento será paralelo.

http://rxwiki.wikidot.com/101samples

Fuente

2011-07-01 02:13:47

Extensiones reactivas Parece bueno, gracias. –

Ok, es el modelo de Programación Reactiva y RX es una implementación de eso. Gracias Hasan –

Creo que sería posible si la cola de hormigón EJECUCIÓ La sincronización está sincronizada, básicamente este es un escenario de consumidor-productor.

Fuente

2011-07-01 02:06:01

¿Uh? Lo siento, no lo entendí en absoluto :( –

Si entiendo tu pregunta correctamente, quieres repetir la misma cola en 2 diferentes para cada uno de los bucles, entonces básicamente tendrías dos hilos cada uno haciendo su para cada ciclo, para que esto funcione, la cola debería admitir la sincronización entre los hilos. –

Oh, lo siento, me refería a la funcionalidad System.Threading.Tasks 'Parallel.ForEach. –

Parece que está hablando de una situación clásica de productor/consumidor. Siempre me sorprende que no haya más soporte directo para este modelo integrado en .Net. Lo más cercano que he encontrado en .Net estuvo oculto en el tiempo de ejecución y simultaneidad de coordinación, que formaba parte de la suite de Microsoft Robotics. Buena suerte encontrándolo ahora.

Pero una vez que sepa qué buscar, un rápido control de Google proporciona algunas otras posibles opciones.

Fuente

2011-07-01 02:08:18

Uso BlockingCollection algo como esto:

var bc = new BlockingCollection<int>(); 
Task.Factory.StartNew(() => 
    { 
     ParallelOptions options = new ParallelOptions 
      { 
       MaxDegreeOfParallelism = 30 
      }; 
     Parallel.ForEach(bc.GetConsumingEnumerable(), options, i => { }); 
    });

Fuente

2012-05-05 12:25:57 Mahesh

Por lo tanto, la tarea esperará hasta que se coloquen nuevos elementos en la colección antes de continuar correctamente? –

Respuesta

Cuestiones relacionadas