CountDownLatch
有什么用?
当我们用多线程处理批量任务时,因为每个线程中没有回调,所以我们不知道所有任务具体的完成时。
这时就可以用到CountDownLatch工具类了。
我们可以将任务量设置到CountDownLatch中开始计数,每完成一个任务处理,CountDownLatch.countDown任务计数剩余。
然后在批处理之外,使用CountDownLatch.await轮询计数量,当任务全部执行完毕,放开阻断,程序流程继续往下。
如何用?具体代码如下
1、比如,我们有10000个任务需要处理,使用线程池来处理,拒绝策略是超出队列调用线程(这里是main线程)执行;
2、使用CountDownLatch多线程计数,任务外,采用await等待,当任务处理完毕,监听放开,继续后续流程;
注意,countDown()方法的使用位置,要包含所有run方法出口CountDownLatch源码分析,待续...
网友评论