CountDownLatch的使用

        在一些应用场合中，需要等待某个条件达到要求后才能做后面的事情；同时当线程都完成后也会触发事件，以便进行后面的操作。 这个时候就可以使用CountDownLatch。CountDownLatch最重要的方法是countDown()和await()，前者主要是倒数一次，后者是等待倒数到0，如果没有到达0，就只有阻塞等待了。

 

        CountDownLatch是一个同步辅助类，在完成一组正在其他线程中执行的操作之前，它允许一个或多个线程一直等待。用给定的计数 初始化 CountDownLatch。由于调用了 countDown() 方法，所以在当前计数到达零之前，await（） 方法会一直受阻塞。之后，会释放所有等待的线程，await 的所有后续调用都将立即返回。

 

下面是一个使用例子：

 

 

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class TestLock {

	static CountDownLatch cdl = null;

	/**
	 * @param args
	 */
	public static void main(String[] args) {

		// 线程池
		final ExecutorService exec = Executors.newCachedThreadPool();

		Runnable main = new Runnable() {
			@Override
			public void run() {
				for (int i = 0; i < 5; i++) {

					cdl = new CountDownLatch(1);// 为每个任务创建一个锁存器,计数器为1

					System.out.println("任务开始:" + i);
					updateData(i);// 模拟业务逻辑数据

					// 模拟自动货架执行
					exec.execute(createTask(i));

					try {
						cdl.await();// 等待任务结束
					} catch (InterruptedException e) {
						e.printStackTrace();
					}

					System.out.println("任务结束:" + i);
				}
				cdl = null;
				System.out.println(cdl);
			}
		};

		exec.execute(main);
	}

	private static void updateData(int i) {
		System.out.println("更新数据:" + i);
	}

	private static Runnable createTask(final int k) {
		return new Runnable() {
			@Override
			public void run() {
				try {
					Thread.sleep(5000);// 模拟执行过程
					System.out.println("自动货架执行完成" + k);

				} catch (InterruptedException e) {
					System.out.println("自动货架执行异常" + k);
					e.printStackTrace();
				} finally {
					cdl.countDown();//计数递减
				}
			}
		};
	}
}