пример CyclicBarier:
public class CyclicBarierExample {
public static void main(String[] args) {
CyclicBarrier cyclicBarrier = new CyclicBarrier(3, new Go());
new Car(cyclicBarrier).setName("Гонщик №1");
new Car(cyclicBarrier).setName("Гонщик №2");
new Car(cyclicBarrier).setName("Гонщик №3");
}
static class Go extends Thread {
@Override
public void run() {
System.out.println("Гонка началась !!!");
}
}
static class Car extends Thread {
final CyclicBarrier barrier;
Car(CyclicBarrier barrier) {
this.barrier = barrier;
start();
}
@Override
public void run() {
System.out.println(Thread.currentThread().getName() + " ожидает начала гонки");
try {
barrier.await();
} catch (InterruptedException | BrokenBarrierException e) {
e.printStackTrace();
}
}
}
}