多线程

CountDownLatch

2019-02-03  本文已影响109人  大黑跟小白的日常

CountDownLatch

有什么用?

当我们用多线程处理批量任务时,因为每个线程中没有回调,所以我们不知道所有任务具体的完成时。

这时就可以用到CountDownLatch工具类了。

我们可以将任务量设置到CountDownLatch中开始计数,每完成一个任务处理,CountDownLatch.countDown任务计数剩余。

然后在批处理之外,使用CountDownLatch.await轮询计数量,当任务全部执行完毕,放开阻断,程序流程继续往下。

如何用?具体代码如下

1、比如,我们有10000个任务需要处理,使用线程池来处理,拒绝策略是超出队列调用线程(这里是main线程)执行;

2、使用CountDownLatch多线程计数,任务外,采用await等待,当任务处理完毕,监听放开,继续后续流程;

注意,countDown()方法的使用位置,要包含所有run方法出口

CountDownLatch源码分析,待续...

上一篇下一篇

猜你喜欢

热点阅读