什么是CountDownLatch

这是一个并发工具，存在于java.util.concurrent包下。 能够使某个线程在其他线程完成任务后继续执行。 CountDownLatch是通过一个计数器来实现的，计数器的初始值设置为需要等待的线程数量，每当一个线程完成了任务，计数器减1，当计数器减到0，表示所有线程完成任务，等待的线程可以继续执行任务。

CountDownLatch如何工作

• new CountDownLatch(10)
• 创建10个线程然后启动
• 主线程await()等待
• 10个线程执行完countdown()
• 主线程恢复执行

三个主要方法：

• 构造方法
• await()
• countDown()

注意：主线程继续执行的条件是count为0，即等待所有子线程执行了countDown()，并不是子线程完成。

如果要等待子线程完成，可以使用 ExecutorService.awaitTermination 或者 Thread.join

If you want to wait for all threads to complete, then you can use ExecutorService.awaitTermination or Thread.join

参考文章

加入一个有趣的小实验

package concurrent;import java.util.concurrent.CountDownLatch;/** * 有趣的实验，主线程等待状态下，子线程中途执行countDown，观察主线程行为 * @author dpc * */public class CountDownLatchTest {	public static void main(String[] args) {		CountDownLatch countDownLatch = new CountDownLatch(4);// latch count初始值，等待线程数为4		Runnable runnable = new Runnable() {			@Override			public void run() {				countDownLatch.countDown();//latch count 减一，当减到0时，主线程继续执行				try {					Thread.sleep(30);//等待30毫秒，观察主线程行为				} catch (InterruptedException e) {					e.printStackTrace();				}				System.out.println(Thread.currentThread().getName() + " end");//子线程结束运行			}		};		try {			new Thread(runnable, "A").start();			new Thread(runnable, "B").start();			new Thread(runnable, "C").start();			new Thread(runnable, "D").start();			countDownLatch.await();//主线程进入等待状态，直到latch count 等于0			System.out.println(Thread.currentThread().getName() + " end");//主线程结束		} catch (InterruptedException e) {			e.printStackTrace();		}	}}

输出:

结论： 可见主线程是否继续执行和子线程是否完成没有必然关系，仅和latch count 的值是否为0有关系。