CountDownLatch的Demo

 1 package com.tjy.concurrentTools;
 2 
 3 import java.util.Random;
 4 import java.util.concurrent.CountDownLatch;
 5 import java.util.concurrent.TimeUnit;
 6 
 7 /**
 8  * 该类要实现10个运动员都准备就绪后，裁判的发令枪后开始跑，使用CountDownLatch实现
 9  */
10 public class SportManRun {
11 
12     private static final int NUMBER = 10;
13     //10个运动员，这里计数10
14     private static CountDownLatch readyLatch = new CountDownLatch(NUMBER);
15     //发令枪只有1次
16     private static CountDownLatch startLatch = new CountDownLatch(1);
17 
18     public static void main(String[] args) {
19         //召唤10个远动员
20         for (int i = 0; i < NUMBER; i++) {
21             Thread runMan = new Thread(new RunningMan(readyLatch, startLatch, "第" + (i + 1) + "运动员"));
22             runMan.start();
23         }
24         try {
25             //等待所有远动员准备就绪
26             readyLatch.await();
27             System.out.println("所有运动员准备就绪了！等待裁判发令枪。。。");
28 
29         } catch (InterruptedException e) {
30             e.printStackTrace();
31         }
32         startLatch.countDown();
33 
34         System.out.println("砰！！！！！！");
35     }
36 
37     static class RunningMan implements Runnable {
38         private CountDownLatch readyLatch;
39         private CountDownLatch startLatch;
40         private String name;
41 
42         public RunningMan(CountDownLatch readyLatch, CountDownLatch startLatch, String name) {
43             this.name = name;
44             this.readyLatch = readyLatch;
45             this.startLatch = startLatch;
46         }
47 
48         @Override
49         public void run() {
50             int prepareTime = new Random().nextInt(6000);
51             System.out.println(name + "需要时间：" + prepareTime + "准备。。。");
52             try {
53                 Thread.sleep(prepareTime);
54             } catch (InterruptedException e) {
55                 e.printStackTrace();
56             }
57             readyLatch.countDown();
58             System.out.println(name + "准备完毕。。。");
59             try {
60                 startLatch.await();
61             } catch (InterruptedException e) {
62                 e.printStackTrace();
63             }
64             System.out.println("开跑！！！！");
65 
66         }
67     }
68 }