CountDownLatch和CyclicBarrier的应用场景

jdk1.5之后，java的concurrent包提供了一些并发工具类，比如CountDownLatch和CyclicBarrier，这里只讲它们的应用场景，暂不作原理剖析。
CountDownLatch：一个线程A等待其它线程都执行完毕后，这个线程A才继续执行。这个线程A也可以是一组线程(使用同一个CountDownLatch来控制即可).
CyclicBarrier：一组线程互相等待，当它们都达到各自await()指定的barrier时，它们再同时继续执行各自下面的代码。

大致实现如下：

CountDownLatch：使用await()让主线程A等待，然后其它线程执行完成时可以使用countDown()使计数减1，最终计数器被清0时，主线程继续执行，计数器是由CountDownLatch初始化时定义的:

final CountDownLatch latch = new CountDownLatch(2);
CyclicBarrier：一组线程使用await()指定barrier，所有线程都到达各自的barrier后，再同时执行各自barrier下面的代码。CyclicBarrier也可以指定当所有线程到达barrier时执行一段代码：

 @Override

 public void run() {

 System.out.println("大家都到了啊!"); 

 });```

还有个工具也很实用，Semaphore，可以控制一段代码块同时被访问的线程的个数。通过 acquire() 获取一个许可，如果没有就等待，而 release() 释放一个许可。

public static void main(String[] args) {

int N = 8; //总线程数

Semaphore semaphore = new Semaphore(5); //最多访问线程数5

for(int i=0;i i++)

 new Worker(i,semaphore).start();

}
static class Worker extends Thread{

private int num;

private Semaphore semaphore;

public Worker(int num,Semaphore semaphore){

 this.num = num;

 this.semaphore = semaphore;

@Override

public void run() {

 try {

 semaphore.acquire();

 //sleep模拟一个代码块，最多只有5个线程能够执行它，其它线程会被阻塞在上面的acquire()方法，

 等待获取许可

 Thread.sleep(2000);

 semaphore.release(); 

 } catch (InterruptedException e) {

 e.printStackTrace();

}

}
}`