社区微信群开通啦,扫一扫抢先加入社区官方微信群
社区微信群
在处理一些耗时操作的时候,我们习惯上会把它放在子线程里面做,是的如果允许(我是指操作的内容),为了更快速地完成这堆操作,线程池是一个不错的选择。等等,好像有点不对,如果需要等待所有的线程在执行完后触发一个操作,这个时候你就需要用到CountDownLatch。
其实这涉及到多线程异步转同步的问题,在java 1.5中,提供了一些非常有用的辅助类来帮助我们进行并发编程,比如CountDownLatch,CyclicBarrier和Semaphore,但是如果需要配合线程池使用,CountDownLatch是不错的选择(Semaphore还没用过。。。所以没选它)。
这里先下个结论:
先看看CountDownLatch提供的方法:
CountDownLatch只有一个构造方法:
public CountDownLatch(int count) { }; //参数count为计数值
然后下面这3个方法是CountDownLatch类中最重要的方法:
//调用await()方法的线程会被挂起,它会等待直到count值为0才继续执行
public void await() throws InterruptedException { };
//和await()类似,只不过等待一定的时间后count值还没变为0的话就会继续执行
public boolean await(long timeout, TimeUnit unit) throws InterruptedException { };
//将count值减1
public void countDown() { };
在看看CyclicBarrier的方法:
public CyclicBarrier(int parties, Runnable barrierAction) {
}
public CyclicBarrier(int parties) {
}
public int await() throws InterruptedException, BrokenBarrierException { };
public int await(long timeout, TimeUnit unit)throws InterruptedException,BrokenBarrierException,TimeoutException { };
看完后你会发现CountDownLatch和CyclicBarrier两者的await方法是会阻塞当前线程的,因此如果在线程池中使用CyclicBarrier,如果线程池的core大小小于parties,线程池中的线程遍一直处于阻塞状态,相反CountDownLatch的countDown()在执行后,完美退出当前线程,但是在开启调用CountDownLatch.await()的时候,需要在子线程中,否则就阻塞了当前线程。
如果觉得我的文章对您有用,请随意打赏。你的支持将鼓励我继续创作!