En Java, ¿cómo espero todas las tareas, pero me detengo al primer error?

Question

Tengo una serie de tareas simultáneas para ejecutar. Si alguno de ellos falla, quiero interrumpirlos a todos y esperar la finalización. Pero suponiendo que ninguno de ellos falle, quiero esperar a que todos terminen.

ExecutorCompletionService parece casi lo que quiero aquí, pero no parece haber una forma de saber si todas mis tareas están hechas, excepto al mantener un conteo separado del número de tareas. (Tenga en cuenta que ambos ejemplos de Javadoc for ExecutorCompletionService hacen un seguimiento del recuento "n" de las tareas y lo utilizan para determinar si el servicio ha finalizado)

¿Estoy pasando por alto algo, o realmente lo hago? tengo que escribir este código yo mismo?

Answer 1

Sí, necesita realizar un seguimiento si está utilizando ExecutorCompletionService. Normalmente, debe llamar a get() en los futuros para ver si se produjo un error. Sin iterar sobre las tareas, ¿de qué otra manera podría decirse que falló?

Answer 2

Si su serie de tareas es de un tamaño conocido, entonces debe usar el segundo ejemplo en el javadoc.

Sin embargo, si no conoce la cantidad de tareas que va a enviar al CompletionService, entonces tiene una especie de problema Productor-Consumidor. Un hilo está produciendo tareas y colocándolos en el ECS, otro estaría consumiendo los futuros de tareas a través de take(). Se podría usar un semáforo compartido, permitiendo al productor llamar a la versión() y al consumidor para llamar a adquirir(). La semántica de finalización dependerá de su aplicación, pero bastaría con un booleano volátil o atómico en el productor para indicar que está hecho.

Sugiero un Semaphore over wait/notify con poll() porque hay un retraso no determinista entre el momento en que se produce una tarea y el tiempo que el futuro de esa tarea está disponible para el consumo. Por lo tanto, el consumidor y el productor deben ser un poco más inteligentes.