Java多线程--10 CountDownLatch

        CountDownLatch是一个倒计数器，在完成一组正在其他线程中执行的操作之前，它允许一个或多个线程一直等待。用给定的计数 初始化 CountDownLatch。由于调用了 countDown() 方法，所以在当前计数到达零之前，await 方法会一直受阻塞。之后，会释放所有等待的线程，await 的所有后续调用都将立即返回。这种现象只出现一次>>计数无法被重置。如果需要重置计数，请考虑使用 CyclicBarrier。

        CountDownLatch有很多用途:

        1、将计数 1 初始化的 CountDownLatch 用作一个简单的开/关锁存器，或入口：在通过调用 countDown() 的线程打开入口前，所有调用 await 的线程都一直在入口处等待。

        2、用 N 初始化的 CountDownLatch 可以使一个线程在 N 个线程完成某项操作之前一直等待，或者使其在某项操作完成 N 次之前一直等待。典型用法是，将一个问题分成 N 个部分，用执行每个部分并让锁存器倒计数的 Runnable 来描述每个部分，然后将所有 Runnable 加入到 Executor 队列。当所有的子部分完成后，协调线程就能够通过 await。（当线程必须用这种方法反复倒计数时，可改为使用 CyclicBarrier。） 

        初始化CountDownLatch时，给定一个数N，await方法会阻塞线程，每调用countDown一下，N就减1 ，当N减到0时，就能执行await后面的程序。

import java.util.concurrent.CountDownLatch;

public class CountDownLatchDemo {

	public static void main(String[] args) {
		
		final CountDownLatch countDown = new CountDownLatch(2);
		
		Thread t1 = new Thread(new Runnable() {
			@Override
			public void run() {
				try {
					System.out.println("进入线程t1" + "等待其他线程处理完成...");
					System.out.println("t1线程 getCount: " + countDown.getCount());
					countDown.await();
					System.out.println("t1线程继续执行...");
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
			}
		},"t1");
		
		Thread t2 = new Thread(new Runnable() {
			@Override
			public void run() {
				try {
					System.out.println("t2线程进行初始化操作...");
					Thread.sleep(3000);
					System.out.println("t2线程初始化完毕，通知t1线程继续...");
					countDown.countDown();
					System.out.println("t2线程 getCount: " + countDown.getCount());
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
			}
		});
		Thread t3 = new Thread(new Runnable() {
			@Override
			public void run() {
				try {
					System.out.println("t3线程进行初始化操作...");
					Thread.sleep(4000);
					System.out.println("t3线程初始化完毕，通知t1线程继续...");
					countDown.countDown();
					System.out.println("t3线程 getCount: " + countDown.getCount());
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
			}
		});
		
		t1.start();
		t2.start();
		t3.start();
	}
}

t1线程进入阻塞状态，t2和t3线程执行完成后，计数器值为0，阻塞解除，才会执行t1线程

打印：

t2线程进行初始化操作...

进入线程t1等待其他线程处理完成...

t3线程进行初始化操作...

t1线程 getCount: 2

t2线程初始化完毕，通知t1线程继续...

t2线程 getCount: 1

t3线程初始化完毕，通知t1线程继续...

t3线程 getCount: 0

t1线程继续执行...

---

---