爱称:并行计数器
简介:简单好用,易上手
image.png
//任务计数
CountDownLatch labelDownLatch = new CountDownLatch(task.size());
taskList.forEach((k, v) -> {
synchronized (labelDownLatch) {
threadPool.execute(() -> {
try {
//查询
} catch (Exception e) {
//exception
} finally {
//防止任务中途出错 主线程一直等待
labelDownLatch.countDown();
//ps:遇到过线程不安全情况 计数出问题 //可以不通过finally 使用await(Long)超时停止
}
});
}
});
//超时时间 防止主线程卡死
labelDownLatch.await(5L, TimeUnit.SECONDS);
网友评论