¿Cómo pongo en pausa main() hasta que todos los demás hilos han muerto?

Question

En mi programa, estoy creando varios hilos en el método main(). La última línea en el método principal es una llamada a System.out.println(), que no deseo llamar hasta que todos los hilos hayan desaparecido. He intentado llamar a Thread.join() en cada hilo, sin embargo, que bloquea cada hilo para que se ejecuten secuencialmente en lugar de en paralelo.

¿Hay alguna manera de bloquear el hilo principal() hasta que todos los otros hilos hayan terminado de ejecutarse? Aquí está la parte relevante de mi código:

public static void main(String[] args) { 

//some other initialization code 

//Make array of Thread objects 
Thread[] racecars = new Thread[numberOfRaceCars]; 

//Fill array with RaceCar objects 
for(int i=0; i<numberOfRaceCars; i++) { 
    racecars[i] = new RaceCar(laps, args[i]); 
} 

//Call start() on each Thread 
for(int i=0; i<numberOfRaceCars; i++) { 
    racecars[i].start(); 
    try { 
     racecars[i].join(); //This is where I tried to using join() 
          //It just blocks all other threads until the current        
          //thread finishes. 
    } catch(InterruptedException e) { 
     e.printStackTrace(); 
    } 
} 

//This is the line I want to execute after all other Threads have finished 
System.out.println("It's Over!"); 

} 

Gracias por la ayuda chicos!

Eric

Answer 1

Inicia sus hilos y espera a que terminen de inmediato (usando join()). En su lugar, usted debe hacer lo join() fuera del bucle en el otro bucle para, por ejemplo .:

// start all threads 
for(int i=0; i<numberOfRaceCars; i++) { 
    racecars[i].start(); 
} 
// threads run... we could yield explicity to allow the other threads to execute 
// before we move on, all threads have to finish 
for(int i=0; i<numberOfRaceCars; i++) { 
    racecars[i].join(); // TODO Exception handling 
} 
// now we can print 
System.out.println("It's over!"); 

Answer 2

Usted podría wait() en el hilo principal y tienen todas las discusiones emiten una notifyAll() y cuando estén listas. Luego, cada vez que el hilo principal se despierta de esa manera, puede verificar si hay al menos un hilo que todavía está vivo, en cuyo caso wait() un poco más.

Answer 3

Se podría hacer la última línea sea en un "seguimiento" hilo. Comprobaría de vez en cuando que es el único hilo en ejecución y algún estado de finalización == true y luego podría disparar si lo fuera. Entonces podría hacer otras cosas además de solo println

Answer 4

Puede usar el método de unión. Consulte la documentación here

Answer 5

Se puede compartir un objeto CyclicBarrier entre sus RaceCar s y el hilo principal, y tienen los hilos invocan RaceCarawait() tan pronto como se hacen con su tarea. Construya la barrera con el número de hilos RaceCar más uno (para el hilo principal). El hilo principal continuará cuando todos los RaceCar hayan terminado. Ver http://java.sun.com/javase/6/docs/api/java/util/concurrent/CyclicBarrier.html

En detalle, construir un CyclicBarrier en el hilo principal, y añadir una llamada barrier.await() en su clase RaceCar justo antes de las salidas run() método, también añadir una llamada barrier.await() antes de la System.out.println() llamada en su hilo principal.

Answer 6

Puede agregar un gancho de apagado para el mensaje "Se acabó". De esta manera, se producirá cuando el programa finalice y no tendrá que esperar cada hilo.

Answer 7

manera más simple

while (Thread.activeCount() > 1) { 
} 

sé que bloquean hilo principal ... pero funciona perfectamente!

Answer 8

probar este ejemplo:

public class JoinTest extends Thread { 

    public static void main(String[] args) 
    { 
     JoinTest t = new JoinTest(); 
     t.start(); 

     try { 

      t.join(); 
      int i = 0; 
      while(i<5) 
      { 
       System.out.println("parent thread is running......" +i++); 
      } 

     } catch (Exception e) { 
      // TODO: handle exception 
     } 


    } 


    public void run() 
    { 

     try { 

      int i =0; 
      while(i<5) 
      { 
       System.out.println("child thread running ........." +i++); 
      } 

     } catch (Exception e) { 
      // TODO: handle exception 
     } 
    } 
} 

Answer 9

Seguro que tiene mejores opciones si vas para ExecutorService o ThreadPoolExecutor marco.

1. invokeAll

   ejecuta las tareas encomendadas, devolviendo una lista de futuros que sostienen su estado y los resultados cuando todos completos. Future.isDone() es verdadero para cada elemento de la lista devuelta. Tenga en cuenta que una tarea completa puede haber terminado normalmente o lanzando una excepción. Los resultados de este método no están definidos si la colección dada se modifica mientras esta operación está en progreso. Parámetros Tipo:

2. CountDownLatch: Inicializar CountDownLatch con contador como el número de hilos. Use countDown() y await() API y espere que el contador se convierta en cero.

Otras referencias:

How to use invokeAll() to let all thread pool do their task?

How is CountDownLatch used in Java Multithreading?