在处理并发请求时,如何知道所有多线程任务都已成功执行是一个常见的问题。在这里,我们将探讨使用CountDownLatch和CompletableFuture来实现此目的的方法。
CountDownLatch
CountDownLatch是一个同步原语,允许一个线程等待一组其他线程完成其任务。通过使用CountDownLatch,我们可以创建一个闩锁,其初始计数等于要执行的任务数。每个任务完成后,它将递减闩锁的计数。主线程可以调用await()方法来等待计数减至0,表明所有任务都已完成。
立即学习“Java免费学习笔记(深入)”;
然后,我们可以创建一个新线程来等待所有请求完成并发送短信。
CompletableFuture
CompletableFuture是一个异步编程API,为异步操作提供支持。我们可以使用CompletableFuture.allOf()方法来等待一组CompletableFuture都完成。以下是如何使用CompletableFuture来实现此目的:
为每个请求创建一个CompletableFuture,并在每个CompletableFuture中执行异步操作。
使用CompletableFuture.allOf()创建一个新的CompletableFuture,它等待所有请求完成。
在allOf()的回调中,发送短信。
这两种方法都可以实现你想要的目的:在主线程不阻塞的情况下,知道多线程任务何时全部执行完毕。具体选择哪种方法将取决于你的场景的具体要求。