java countDownLatch概念

  • countDownLatch这个类使一个线程等待其他线程各自执行完毕后再执行。
  • 是通过一个计数器来实现的，计数器的初始值是线程的数量。每当一个线程执行完毕后，计数器的值就-1，当计数器的值为0时，表示所有线程都执行完毕，然后在闭锁上等待的线程就可以恢复工作了。

例子

班长最后走锁门的例子，有6个同学上晚自习，班长必须等6个同学都走完才能锁门，不然把其中一个锁教室了班长就等着被骂娘。

代码实现

  • 一般情况，可能出现班长把其中几个人锁教室了，这样时不行的
  1. package com.bowen;
  3. public class CountDownLatchDemo {
  4.     public static void main(String[] args) {
  5.         for (int i = 1; i <= 6; i++) {
  6.             new Thread(()->{
  7.                 System.out.println(Thread.currentThread().getName()+" 同学上完晚自习离开");
  8.             },String.valueOf(i)).start();
  9.         }
  11.         System.out.println(Thread.currentThread().getName()+" 班长锁门离开");
  12.     }
  13. }
  14. //结果
  15. //6 同学上完晚自习离开
  16. //3 同学上完晚自习离开
  17. //2 同学上完晚自习离开
  18. //1 同学上完晚自习离开
  19. //main 班长锁门离开
  20. //5 同学上完晚自习离开
  21. //4 同学上完晚自习离开
  • 修改后,一定等到6个同学都走完，班长才锁门
  1. package com.bowen;
  3. import java.util.concurrent.CountDownLatch;
  5. public class CountDownLatchDemo {
  6.     public static void main(String[] args) throws InterruptedException {
  7.         CountDownLatch countDownLatch = new CountDownLatch(6);//初始化 cout为6
  8.         for (int i = 1; i <= 6; i++) {
  9.             new Thread(()->{
  10.                 System.out.println(Thread.currentThread().getName()+" 同学上完晚自习离开");
  11.                 countDownLatch.countDown();//走一个减一
  12.             },String.valueOf(i)).start();
  13.         }
  15.         countDownLatch.await();//减到0才不会再等待
  16.         System.out.println(Thread.currentThread().getName()+" 班长锁门离开");
  17.     }
  18. }
  19. //结果
  20. //6 同学上完晚自习离开
  21. //5 同学上完晚自习离开
  22. //2 同学上完晚自习离开
  23. //1 同学上完晚自习离开
  24. //4 同学上完晚自习离开
  25. //3 同学上完晚自习离开
  26. //main 班长锁门离开