前言

之前学多线程的时候没有学习线程的同步工具类(辅助类)。ps:当时觉得暂时用不上，认为是挺高深的知识点就没去管了..

在前几天，朋友发了一篇比较好的Semaphore文章过来，然后在浏览博客的时候又发现面试还会考，那还是挺重要的知识点。于是花了点时间去了解一下。

Java为我们提供了三个同步工具类：

• CountDownLatch(闭锁)

• CyclicBarrier(栅栏)

• Semaphore(信号量)

这几个工具类其实说白了就是为了能够更好控制线程之间的通讯问题~

一、CountDownLatch

1.1CountDownLatch简介

• A synchronization aid that allows one or more threads to wait until a set of operations being performed in other threads completes.

简单来说：CountDownLatch是一个同步的辅助类，允许一个或多个线程一直等待，直到其它线程完成它们的操作。

它常用的API其实就两个:await()和countDown()

image

使用说明：

• count初始化CountDownLatch，然后需要等待的线程调用await方法。await方法会一直受阻塞直到count=0。而其它线程完成自己的操作后，调用countDown()使计数器count减1。当count减到0时，所有在等待的线程均会被释放

• 说白了就是通过count变量来控制等待，如果count值为0了(其他线程的任务都完成了)，那就可以继续执行。

1.2CountDownLatch例子

例子：3y现在去做实习生了，其他的员工还没下班，3y不好意思先走，等其他的员工都走光了，3y再走。

import java.util.concurrent.CountDownLatch;public class Test {    public static void main(String[] args) {        final CountDownLatch countDownLatch = new CountDownLatch(5);

        System.out.println("现在6点下班了.....");        // 3y线程启动
        new Thread(new Runnable() {            @Override
            public void run() {           
                try {                    // 这里调用的是await()不是wait()
                    countDownLatch.await();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("...其他的5个员工走光了，3y终于可以走了");
            }
        }).start();        // 其他员工线程启动
        for (int i = 0; i < 5; i++) {            new Thread(new Runnable() {                @Override
                public void run() {
                    System.out.println("员工xxxx下班了");
                    countDownLatch.countDown();
                }
            }).start();
        }
    }
}

输出结果：

image

再写个例子：3y现在负责仓库模块功能，但是能力太差了，写得很慢，别的员工都需要等3y写好了才能继续往下写。

import java.util.concurrent.CountDownLatch;public class Test {    public static void main(String[] args) {        final CountDownLatch countDownLatch = new CountDownLatch(1);        // 3y线程启动
        new Thread(new Runnable() {            @Override
            public void run() {                try {
                    Thread.sleep(5);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("3y终于写完了");
                countDownLatch.countDown();

            }
        }).start();        // 其他员工线程启动
        for (int i = 0; i < 5; i++) {            new Thread(new Runnable() {                @Override
                public void run() {
                    System.out.println("其他员工需要等待3y");                    try {
                        countDownLatch.await();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    System.out.println("3y终于写完了，其他员工可以开始了！");
                }
            }).start();
        }
    }
}

输出结果：

作者：Java3y
链接：https://www.jianshu.com/p/fbe44c0eb400