import java.util.concurrent.BrokenBarrierException; import java.util.concurrent.CyclicBarrier; class CyclicBarrierWorker implements Runnable {     private int id;     private CyclicBarrier barrier;     public CyclicBarrierWorker(int id, final CyclicBarrier barrier) {         this.id = id;         this.barrier = barrier;     }     @Override     public void run() {         // TODO Auto-generated method stub         try {             System.out.println(id + " th people wait");             barrier.await(); // 大家等待最后一个线程到达         } catch (InterruptedException | BrokenBarrierException e) {             // TODO Auto-generated catch block             e.printStackTrace();         }     } } public class TestCyclicBarrier {     public static void main(String[] args) {         int num = 10;         CyclicBarrier barrier = new CyclicBarrier(num, new Runnable() {             @Override             public void run() {                 // TODO Auto-generated method stub                 System.out.println("go on together!");             }         });         for (int i = 1; i <= num; i++) {             new Thread(new CyclicBarrierWorker(i, barrier)).start();         }     } }

1 th people wait 2 th people wait 3 th people wait 4 th people wait 5 th people wait 7 th people wait 8 th people wait 6 th people wait 9 th people wait 10 th people wait go on together!