高并发编程之CountDownLatch工具类讲解

一、CountDownLatch介绍
CountDownLatch是一个同步工具类，用来协调多个线程之间的同步，或者说起到线程之间的通信（而不是用作互斥的作用）。
CountDownLatch能够使一个线程在等待另外一些线程完成各自工作之后，再继续执行。使用一个计数器进行实现。计数器初始值为线程的数量。当每一个线程完成自己任务后，计数器的值就会减一。当计数器的值为0时，表示所有的线程都已经完成了任务，然后在CountDownLatch上等待的线程就可以恢复执行任务。

二、场景模拟
模拟煮面，步骤：1.需要将水煮开（需要3分钟），2.将准备好的食材放进去（2分钟），3.等待面煮熟。如果按照串行程序来完成这件事情，一共需要5分钟（单个线程来完成）。如果两个线程合作来完成这件事，一个负责将水煮开，另外一个准备好食材，一共则需要3分钟。

这个场景可以用CountDownLatch来完成这件事情，可以节省很多时间。

三、Java代码示例

package chapter3.countdownlatch;import java.util.concurrent.CountDownLatch;/*** @author czd*/
public class CountDownLatchTest {public static void main(String[] args) {final CountDownLatch countDownLatch = new CountDownLatch(1);new Thread(){@Overridepublic void run() {System.out.println("我要将水煮开（需要3分钟）.....现在有一批食材要处理，我需要另外一个人帮我处理");try {//模拟做事情所需要的时间Thread.sleep(3000);countDownLatch.await();System.out.println("这个时候可以等待面煮熟了....");}catch (Exception e){e.printStackTrace();}}}.start();new Thread(){@Overridepublic void run() {System.out.println("我在准备一些食材....（需要2分钟）");try {//模拟做事情所需要的时间Thread.sleep(3000);System.out.println("食材准备好了！花费2分钟");}catch (Exception e){e.printStackTrace();}finally {countDownLatch.countDown();}}}.start();try {countDownLatch.await();}catch (Exception e){e.printStackTrace();}System.out.println("一共花费3分钟！");}
}

四、输出结果

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！