CountDownLatch 基础用法

 

   java.util.concurrent.CountDownLatch 

   一个同步辅助类，在完成一组正在其他线程中执行的操作之前，它允许一个或多个线程一直等待。

 用给定的计数 初始化 CountDownLatch。由于调用了 countDown() 方法，所以在当前计数到达零之前，  await 方法会一直受阻塞。到达0之后，会释放所有等待的线程，执行await 后续操作。

 

   最常见的使用场景: 等待其他线程处理完才继续当前线程。

 

最重要的是使用非常简单!    

 

   使用方法3步走:

 

/**
 * step.1
 * 创建CountDownLatch 实例  预定计数次数:2
 */
CountDownLatch latch = new CountDownLatch(2);

/**
 * step.2
 * 递减锁存器的计数，如果计数到达零，则释放所有等待的线程。 
 * 如果当前计数大于零，则将计数减少 1
 */
latch.countDown();

/**
 * step.3
 * 使当前线程在锁存器倒计数至零之前一直等待，除非线程被中断
 * 如果当前的计数为零，则此方法立即返回
 */
latch.await();

 

 

   示例

final int count = 10; // 计数次数
final CountDownLatch latch = new CountDownLatch(count);
for (int i = 0; i < count; i++) {
	new Thread(new Runnable() {
		@Override
		public void run() {
			try {
				// do anything
				System.out.println("线程"
						+ Thread.currentThread().getId());
			} catch (Throwable e) {
				// whatever
			} finally {
				// 很关键, 无论上面程序是否异常必须执行countDown,否则await无法释放
				latch.countDown();
			}
		}
	}).start();
}
try {
	// 10个线程countDown()都执行之后才会释放当前线程,程序才能继续往后执行
	latch.await();
} catch (InterruptedException e) {
	// whatever
}
System.out.println("Finish");

 

   java.util.concurrent.CyclicBarrier 循环屏障(可重用)

  一组线程内部全部调用await()挂起进入屏障状态后所有线程变成可执行状态.