Jak uzyskać java.concurrency.CyclicBarrier do pracy zgodnie z oczekiwaniami

Question

Piszę kod, który spawnuje dwa wątki, a następnie czeka na ich synchronizację przy użyciu klasy CyclicBarrier. Problem polega na tym, że cykliczna bariera nie działa zgodnie z oczekiwaniami, a główny wątek nie czeka na zakończenie poszczególnych wątków. Oto, jak wygląda mój kod:

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"); 
    } 
} 

Każdy pomysł, co robię źle? Czy istnieje lepszy sposób na zapisanie tych metod synchronizacji barier? Proszę pomóż.

Answer 1

Podczas wykonywania twojej w wątku tworzysz dwa inne wątki i każ im czekać na siebie nawzajem. Ale nic nie napisałeś, aby główny wątek na nich czekał i narzekasz, że nie czeka. Wypróbuj

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. Nie rozszerzaj klasy wątków, chyba że musisz. Implementuj Runnable i przekazuj implementacje do obiektów Thread. Tak:

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

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

EDIT
Uzasadnienie dla uniknięcia rozciągający wątek.
Regułą jest jak najmniejsze sprzężenie. Dziedziczenie to bardzo silny związek między klasami. Musisz dziedziczyć z wątku, jeśli chcesz zmienić niektóre jego domyślne zachowanie (to znaczy zastąpić niektóre metody) lub chcesz uzyskać dostęp do niektórych chronionych pól wątku klasy. Jeśli nie chcesz tego, wybierz luźniejsze sprzężenie - implementacja Runnable i przekazanie go jako parametru konstruktora do instancji Thread.

Answer 2

Przekaż instancję Runnable do konstruktora swojego modelu CyclicBarrier w ten sposób.

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

Szukasz Thread.join() metody ...

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

EDIT: z powodu komentarzach ...

A jeśli nie chcesz czekać w nieskończoność można określ także maksymalną liczbę milisekund plus nanosekund, aby poczekać na zgon wątku.

Answer 4

Cykliczna bariera nie jest właściwym wyborem w tym przypadku. Musisz użyć tutaj CountDownLatch.

Zakładam, że wywołałeś metodę spawnAndWait z metody głównej.

Powodem tego nie jest to, że CyclicBarrier ma 2 konstruktorów. Aby wykonywać operacje po zakończeniu, musisz użyć konstruktora z dwoma parametrami. Najważniejszą rzeczą do zapamiętania jest to, że główny wątek nie będzie czekać przez metodę await; ale nadal będzie wykonywany. Jednak wątek określony w konstruktorze CyclicBarrier będzie działał tylko wtedy, gdy wszystkie zarodkowane wątki zatrzymają się przy barierce (metoda await).