轩辕李的博客 轩辕李的博客
首页
  • Java
  • Spring
  • 其他语言
  • 工具
  • HTML&CSS
  • JavaScript
  • 分布式
  • 代码质量管理
  • 基础
  • 操作系统
  • 计算机网络
  • 编程范式
  • 安全
  • 中间件
  • 心得
关于
  • 分类
  • 标签
  • 归档
GitHub (opens new window)

轩辕李

勇猛精进,星辰大海
首页
  • Java
  • Spring
  • 其他语言
  • 工具
  • HTML&CSS
  • JavaScript
  • 分布式
  • 代码质量管理
  • 基础
  • 操作系统
  • 计算机网络
  • 编程范式
  • 安全
  • 中间件
  • 心得
关于
  • 分类
  • 标签
  • 归档
GitHub (opens new window)
  • Java

    • 核心

    • 并发

      • Java并发-线程基础与synchronized关键字
      • Java并发-重入锁ReetrantLock的使用
      • Java并发-信号量Semaphore
      • Java并发-读写锁ReadWriteLock
      • Java并发-倒计时器CountDownLatch
      • Java并发-栅栏CyclicBarrier
      • Java并发-LockSupport线程阻塞工具类
      • Java并发-线程池ThreadPoolExecutor
      • Java并发-阻塞队列BlockingQueue
      • Java并发-以空间换时间之ThreadLocal
      • Java并发-无锁策略CAS与atomic包
      • Java并发-JDK并发容器
      • Java并发-异步调用结果之Future和CompletableFuture
      • Java并发-Fork Join框架
      • Java并发-调试与诊断
    • 经验

    • JVM

    • 企业应用

  • Spring

  • 其他语言

  • 工具

  • 后端
  • Java
  • 并发
轩辕李
2018-06-11

Java并发-倒计时器CountDownLatch

今天讲一个倒计时器工具,叫CountDownLatch。需要这个工具的场景大概有:当所有的小任务都完成之后,再启动大任务。

先看代码:

public class CountDownLatchDemo {
	static final CountDownLatch LATCH = new CountDownLatch(10);

	public static class Task implements Runnable {
		final static AtomicInteger incr = new AtomicInteger();

		@Override
		public void run() {
			try {
				Thread.sleep(new Random().nextInt(10)*100);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
			System.out.println("火箭检测任务-" + incr.getAndIncrement() + " 完成");
			LATCH.countDown();
		}

	}
	
	public static void main(String[] args) throws InterruptedException {
		ExecutorService executorService = Executors.newFixedThreadPool(10);
		for (int i = 0; i < 10; i++) {
			executorService.execute(new Task());
		}
		LATCH.await();
		System.out.println("发射火箭");
		executorService.shutdown();
	}
}

这里模拟了火箭发射的场景,所有预备任务完成,才能发射火箭。
CountDownLatch比较简单,一个构造加上两个主要方法:

  • 构造函数需要入参一个总数,表示有几个小任务需要执行
  • countDown() 每次执行完小任务都要调用这个方法,用来倒计时
  • await() 没有倒计时到0,就会一直阻塞。当倒计时完成,则继续执行后续代码
编辑 (opens new window)
#CountDownLatch
上次更新: 2023/06/14
Java并发-读写锁ReadWriteLock
Java并发-栅栏CyclicBarrier

← Java并发-读写锁ReadWriteLock Java并发-栅栏CyclicBarrier→

最近更新
01
Spring Boot版本新特性
09-15
02
Spring框架版本新特性
09-01
03
Spring Boot开发初体验
08-15
更多文章>
Theme by Vdoing | Copyright © 2018-2025 京ICP备2021021832号-2 | MIT License
  • 跟随系统
  • 浅色模式
  • 深色模式
  • 阅读模式