CountDownLatch 、CyclicBarrier和Semaphore

　在java 1.5中，提供了一些很是有用的辅助类来帮助咱们进行并发编程，好比CountDownLatch，CyclicBarrier和Semaphore

一.CountDownLatch用法

CountDownLatch类位于java.util.concurrent包下，利用它能够实现相似计数器的功能。好比有一个任务A，它要等待其余4个任务执行完毕以后才能执行，此时就能够利用CountDownLatch来实现这种功能了。

 

CountDownLatch类只提供了一个构造器：

public CountDownLatch(int count) {  };  //参数count为计数值

而后下面这3个方法是CountDownLatch类中最重要的方法

public void await() throws InterruptedException { };   //调用await()方法的线程会被挂起，它会等待直到count值为0才继续执行

public boolean await(long timeout, TimeUnit unit) throws InterruptedException { };  //和await()相似，只不过等待必定的时间后count值还没变为0的话就会继续执行

public void countDown() { };  //将count值减1

 

二.CyclicBarrier用法

字面意思回环栅栏，经过它能够实现让一组线程等待至某个状态以后再所有同时执行。叫作回环是由于当全部等待线程都被释放之后，CyclicBarrier能够被重用。咱们暂且把这个状态就叫作barrier，当调用await()方法以后，线程就处于barrier了。

 

CyclicBarrier类位于java.util.concurrent包下，CyclicBarrier提供2个构造器：

public CyclicBarrier(int parties, Runnable barrierAction) {

}

 

public CyclicBarrier(int parties) {

}

参数parties指让多少个线程或者任务等待至barrier状态；参数barrierAction为当这些线程都达到barrier状态时会执行的内容。

 

而后CyclicBarrier中最重要的方法就是await方法，它有2个重载版本：

public int await() throws InterruptedException, BrokenBarrierException { }; public int await(long timeout, TimeUnit unit)throws InterruptedException,BrokenBarrierException,TimeoutException { };

 

CyclicBarrier是能够重用的，而CountDownLatch没法进行重复使用

 

三.Semaphore用法

Semaphore翻译成字面意思为 信号量，Semaphore能够控同时访问的线程个数，经过 acquire() 获取一个许可，若是没有就等待，而 release() 释放一个许可。

Semaphore类位于java.util.concurrent包下，它提供了2个构造器：

public Semaphore(int permits) {          //参数permits表示许可数目，即同时能够容许多少线程进行访问

    sync = new NonfairSync(permits);

}

public Semaphore(int permits, boolean fair) {    //这个多了一个参数fair表示是不是公平的，即等待时间越久的越先获取许可

    sync = (fair)? new FairSync(permits) : new NonfairSync(permits);

}

 

下面说一下Semaphore类中比较重要的几个方法，首先是acquire()、release()方法：

public void acquire() throws InterruptedException {  }     //获取一个许可

public void acquire(int permits) throws InterruptedException { }    //获取permits个许可

public void release() { }          //释放一个许可

public void release(int permits) { }    //释放permits个许可

acquire()用来获取一个许可，若无许可可以得到，则会一直等待，直到得到许可。

release()用来释放许可。注意，在释放许可以前，必须先获得到许可。

这4个方法都会被阻塞，若是想当即获得执行结果，可使用下面几个方法：

public boolean tryAcquire() { };    //尝试获取一个许可，若获取成功，则当即返回true，若获取失败，则当即返回false public boolean tryAcquire(long timeout, TimeUnit unit) throws InterruptedException { };  //尝试获取一个许可，若在指定的时间内获取成功，则当即返回true，不然则当即返回false public boolean tryAcquire(int permits) { }; //尝试获取permits个许可，若获取成功，则当即返回true，若获取失败，则当即返回false public boolean tryAcquire(int permits, long timeout, TimeUnit unit) throws InterruptedException { }; //尝试获取permits个许可，若在指定的时间内获取成功，则当即返回true，不然则当即返回false

 

下面对上面说的三个辅助类进行一个总结：

　　1）CountDownLatch和CyclicBarrier都可以实现线程之间的等待，只不过它们侧重点不一样：

　　　　CountDownLatch通常用于某个线程A等待若干个其余线程执行完任务以后，它才执行；

　　　　而CyclicBarrier通常用于一组线程互相等待至某个状态，而后这一组线程再同时执行；

　　　　另外，CountDownLatch是不可以重用的，而CyclicBarrier是能够重用的。

　　2）Semaphore其实和锁有点相似，它通常用于控制对某组资源的访问权限。