¿Cómo consigo que java.concurrency.CyclicBarrier funcione como se espera?

Question

Estoy escribiendo un código que engendrará dos hilos y luego esperará que se sincronicen usando la clase CyclicBarrier. El problema es que la barrera cíclica no está funcionando como se esperaba y el hilo principal no espera a que terminen los hilos individuales. Así es como se ve mi código:

class mythread extends Thread{ 
    CyclicBarrier barrier; 
    public mythread(CyclicBarrier barrier) { 
     this.barrier = barrier; 
     } 

    public void run(){ 
      barrier.await(); 
     } 
} 



class MainClass{ 
public void spawnAndWait(){ 
    CyclicBarrier barrier = new CyclicBarrier(2); 
    mythread thread1 = new mythread(barrier).start(); 
    mythread thread2 = new mythread(barrier).start(); 
    System.out.println("Should wait till both threads finish executing before printing this"); 
    } 
} 

¿Alguna idea de lo que estoy haciendo mal? ¿O hay una mejor manera de escribir estos métodos de sincronización de barrera? Por favor ayuda.

Answer 1

Durante la ejecución de su ma en el hilo, crea otros dos hilos y les dice que esperen el uno al otro. Pero no escribió nada para que su hilo principal los aguarde y se queje de que no espera. Pruebe

CyclicBarrier barrier = new CyclicBarrier(3); 
mythread thread1 = new mythread(barrier).start(); 
mythread thread2 = new mythread(barrier).start(); 
barrier.await(); // now you wait for two new threads to reach the barrier. 
System.out.println("Should wait till both threads finish executing before printing this"); 

BTW. No extienda la clase Thread a menos que sea necesario. Implementa Runnable y pasa implementaciones a Thread objects. De esta manera:

class MyRunnable implements Runnable { 
    public void run(){ 
     // code to be done in thread 
    } 
} 

Thread thread1 = new Thread(MyRunnable); 
thread1.start(); 

EDITAR
Justificación para evitar que se extiende del hilo.
La regla de oro es el menor acoplamiento posible. La herencia es una conexión muy fuerte entre clases. Debe heredar de Thread si desea cambiar parte de su comportamiento predeterminado (es decir, anular algunos métodos) o si desea acceder a algunos campos protegidos de la clase Thread. Si no lo deseas, eliges un acoplamiento más flexible: implementa Runnable y lo pasa como un parámetro constructor a la instancia Thread.

Answer 2

Pase una instancia Runnable al constructor de su CyclicBarrier de esta manera.

CyclicBarrier barrier = new CyclicBarrier(2, new Runnable() { 

    @Override 
    public void run() { 
     System.out.println("Should wait till both threads finish executing before printing this"); 
    } 
}); 

new mythread(barrier).start(); 
new mythread(barrier).start(); 

Answer 3

Usted está buscando Thread.join() método ...

thread1.join(); 
thread2.join(); 
System.out.println("Finished"); 

EDIT: debido a los comentarios ...

Y si usted no quiere esperar para siempre que pueda también especifique la cantidad máxima de milisegundos más nanosegundos para esperar a que el hilo muera

Answer 4

La barrera cíclica no es la elección correcta en este caso. Debe usar CountDownLatch aquí.

Supongo que está invocando el método spawnAndWait del método principal.

La razón por la que esto no funciona es que el CyclicBarrier tiene 2 constructores. Para realizar post-operaciones, debe usar un constructor de 2 parámetros. Lo más importante que debe recordar es que el hilo principal no esperará por el método await; pero continuará ejecutándose. Sin embargo, el subproceso especificado en el constructor CyclicBarrier solo se ejecutará cuando todos los subprocesos generados se detengan en la barrera (por el método await)