多线程之CountDownLatch

2019-04-14 17:56发布

站内文章 / 模拟电子
11746 0 1687
package com.test.thread; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class CountDownLatchTest { // 模拟了100米赛跑，10名选手已经准备就绪，只等裁判一声令下。当所有人都到达终点时，比赛结束。 public static void main(String[] args) throws InterruptedException { // 开始的倒数锁 final CountDownLatch begin = new CountDownLatch(1); // 结束的倒数锁 final CountDownLatch end = new CountDownLatch(10); // 十名选手 final ExecutorService exec = Executors.newFixedThreadPool(10); for (int index = 0; index < 10; index++) { final int NO = index + 1; Runnable run = new Runnable() { public void run() { try { //如果当前计数为不为零，一直等待休眠状态，等于0就开跑啦 begin.await();//模拟运动员准备就绪，只等裁判一声枪响 Thread.sleep((long) (Math.random() * 10000)); System.out.println("No." + NO + " arrived"); } catch (InterruptedException e) { } finally { // 每个选手到达终点时，end就减一 end.countDown(); } } }; exec.submit(run); } //裁判休息了10秒，在准备叫游戏开始--裁判没叫开始谁先跑了，就下课 //裁判也是人，要休息下的。 Thread.sleep(10000); System.out.println("Game Start"); // begin减一，开始游戏，相当裁判的命令枪声 begin.countDown(); // 等待end变为0，即所有选手到达终点 end.await(); System.out.println("Game Over"); exec.shutdown(); } }
总结：CountDownLatch这例子是我搬的别人的，业务场景我还真没发现。            我先是各种DEBUG后，加了不少注释





热门文章