如何检测多线程执行完毕
为了提高数据处理效率，您希望并发调用第三方接口，并在所有调用完成后发送短信。但是，使用 future.get() 会阻塞主线程，因为您需要等待所有线程执行完毕。
解决这个问题的一种方法是使用 countdownlatch。countdownlatch 提供一个计数器，它跟踪尚未完成的任务数量。
在多线程处理中，每个线程完成其任务后，使用 countdown() 方法递减计数器。当计数器变为零时，它表示所有任务都已完成。
这里是如何使用 countdownlatch 检测多线程执行完毕：
int requestcount = 1000;
countdownlatch latch = new countdownlatch(requestcount);
for (int i = 0; i < requestcount; i++) {
new thread(() -> {
// 调用第三方接口
// ...
// 操作完成，递减计数器
latch.countdown();
}).start();
}
// 新开一个线程等待所有请求完成后发送短信
new thread(() -> {
try {
latch.await();
// 所有请求完成，发送短信
// ...
} catch (interruptedexception e) {
e.printstacktrace();
}
}).start();另一种方法是使用 completablefuture.allof。它可以组合多个 completablefuture 实例，并在所有 completablefuture 完成时执行一个操作。
completablefuture[] futures = new completablefuture[requestcount];
for (int i = 0; i < requestcount; i++) {
futures[i] = completablefuture.runasync(() -> {
// 调用第三方接口
// ...
});
}
// 所有请求完成后发送短信
completablefuture.allof(futures).thenrun(() -> {
// 发送短信
// ...
});为了进一步提高并发性，您可以使用自定义线程池来执行异步任务，如下所示：
ExecutorService executor = Executors.newFixedThreadPool(100);
CompletableFuture[] futures = new CompletableFuture[requestCount];
for (int i = 0; i < requestCount; i++) {
futures[i] = CompletableFuture.runAsync(() -> {
// 调用第三方接口
// ...
}, executor); // 用自定义线程池
}
// 所有请求完成后发送短信
CompletableFuture.allOf(futures).thenRun(() -> {
// 发送短信
// ...
}).thenRun(() -> executor.shutdown()); // 所有任务完成后关闭线程池通过使用 countdownlatch 或 completablefuture.allof，您可以异步处理任务，并在所有任务完成时执行后续操作，而不会阻塞主线程。
