多线程 第七节 CountDownLatch 与 CyclicBarrier

    科技2026-09-26  12

    CountDownLatch线程计数器

    1、    CountDownLatch位于java.util.concurrent 包下,是一个非常实用的多线程控制工具类,称之为“倒计时器”,它允许一个或多个线程一直等待,直到其他线程的操作执行完后再执行。 2、    CountDownLatch 是通过一个计数器来实现的,计数器的初始值为线程的数量。每当一个线程完成了自己的任务后,计数器的值就会减1。当计数器值到达0时,表示所有的线程已经完成了任务,然后在闭锁上等待的线程就可以恢复执行任务。 3、    CountDownLatch 有两个重要的方法:     countDown():使计数器减 1     await():当计数器不为 0 时,则调用该方法的线程阻塞,当计数器为 0 时,可以唤醒等待的一个或者全部线程 4、    使用场景: 去医院体检,通常人们会提前去医院排队,但只有等到医生开始上班,才能正式开始体检,医生也要给所有人体检完才能下班,这种情况就要使用 CountDownLatch,流程为:患者排队 → 医生上班 → 体检完成 → 医生下班。

    public class CountDownLatchTest { private static final int COUNT_DOWN_LATCH_NUM = 9; private static CountDownLatch countDownLatch = new CountDownLatch(COUNT_DOWN_LATCH_NUM); public static void main(String[] args) throws Exception{ for (int i = 0; i < COUNT_DOWN_LATCH_NUM; i++) { new Thread(){ @Override public void run() { try { System.out.println("线程" + Thread.currentThread().getName() + "报道。"); Thread.sleep(new Random().nextInt(3000)); countDownLatch.countDown(); } catch (InterruptedException e) { e.printStackTrace(); } } }.start(); } countDownLatch.await(); System.out.println("人齐了,可以出发了"); } }

    CyclicBarrier循环屏障 

    CyclicBarrier 让一组线程到达一个屏障(也可以叫同步点)时被阻塞,直到最后一个线程到达屏障时,屏障才会开门,所有被屏障拦截的线程才会继续干活。

    import java.util.concurrent.CyclicBarrier; public class CyclicBarrierTest { private static final int THREAD_COUNT_NUM = 9; public static void main(String[] args) { firstTask(); } private static void firstTask(){ CyclicBarrier cyclicBarrier = new CyclicBarrier(THREAD_COUNT_NUM, new Runnable() { @Override public void run() { System.out.println("第一阶段任务已经完成,开始下一阶段"); secondTask(); } }); task("第一阶段:第", "第一阶段任务已经完成,结束", cyclicBarrier); } private static void secondTask(){ CyclicBarrier cyclicBarrier = new CyclicBarrier(THREAD_COUNT_NUM, new Runnable() { @Override public void run() { System.out.println("第二阶段任务已经完成,开始下一阶段"); thirdTask(); } }); task("第二阶段:第", "第二阶段任务已经完成,结束", cyclicBarrier); } private static void thirdTask(){ CyclicBarrier cyclicBarrier = new CyclicBarrier(THREAD_COUNT_NUM, new Runnable() { @Override public void run() { System.out.println("第三阶段任务已经完成,结束"); } }); task("第三阶段:第", "第三阶段任务已经完成,结束", cyclicBarrier); } }

    CyclicBarrier 和 CountDownLatch 的区别 

     1、    CountDownLatch 的计数器只能使用一次。而 CyclicBarrier 的计数器可以使用 reset() 方法重置。所以 CyclicBarrier 能处理更为复杂的业务场景,比如如果计算发生错误,可以重置计数器,并让线程们重新执行一次。 2、    CyclicBarrier 还提供其他有用的方法,比如 getNumberWaiting 方法可以获得 CyclicBarrier 阻塞的线程数量。isBroken 方法用来知道阻塞的线程是否被中断。 3、    CountDownLatch 会阻塞主线程,CyclicBarrier 不会阻塞主线程,只会阻塞子线程。

     

    Processed: 0.008, SQL: 9