CountDownLatch的使用
2024/9/19...小于 1 分钟
CountDownLatch的使用
CountDownLatch countDownLatch = new CountDownLatch(list.size());
for (String item : list) {
threadPool.execute(() -> {
try {
// 处理业务
// doItem(item);
} catch (Exception e) {
log.error("处理业务失败", e);
} finally {
countDownLatch.countDown();
}
});
}
try {
countDownLatch.await();
} catch (InterruptedException e) {
log.error("业务失败", e);
throw new ServiceException("业务失败");
}