java的CyclicBarrier

 1 public class Test {
 2 
 3     private static Executor executor = Executors.newCachedThreadPool();
 4 
 5     public static void main(String[] args) throws InterruptedException {
 6         int sporterCount = 5;
 7         CyclicBarrier cyclicBarrier = new CyclicBarrier(sporterCount, new Runnable() {
 8             @Override
 9             public void run() {
10                 System.out.println("吹黑哨。。。");
11             }
12         });
13         for (int i = 0; i < sporterCount; i++) {
14             executor.execute(new Sporter(i + 1, cyclicBarrier));
15         }
16     }
17 }
18 
19 
20 class Sporter implements Runnable {
21 
22     private int no;
23     private CyclicBarrier cyclicBarrier;
24 
25     public Sporter(int no, CyclicBarrier cyclicBarrier) {
26         this.no = no;
27         this.cyclicBarrier = cyclicBarrier;
28     }
29 
30     @Override
31     public void run() {
32         System.out.println("第" + no + "号已经准备好");
33         try {
34             this.cyclicBarrier.await();//通知吹黑哨的准备好了
35         } catch (InterruptedException e) {
36             e.printStackTrace();
37         } catch (BrokenBarrierException e) {
38             e.printStackTrace();
39         }
40         System.out.println("第" + no + "号已开跑");
41     }
42 }

第1号已经准备好
第4号已经准备好
第3号已经准备好
第5号已经准备好
第2号已经准备好
吹黑哨。。。
第2号已开跑
第1号已开跑
第4号已开跑
第3号已开跑
第5号已开跑