CompletableFuture 子线程出现问题会导致 CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])).join(); 无限等待吗？如何避免这种情况发生

`CompletableFuture.allOf()` 方法用于等待一组 `CompletableFuture` 完成，如果其中任何一个任务抛出异常，整个操作会立即失败并返回那个异常。当传入的 `futures` 集合有一个或多个完成任务抛出了错误，`allOf().join()` 将会阻塞，直到这个错误被注意到。

如果你的一个子线程抛出未检查异常 (如 `InterruptedException`, `ExecutionException` 的子类)，这可能会导致 `allOf().join()` 永远等待，因为你默认地捕获了所有 `Future` 中可能出现的异常，并且 `CompletableFuture` 并不会自动将中断传递给主线程。

为了避免这种情况，你可以：

1. **处理中断**：在使用 `.join()` 或其他同步操作之前，确保捕获并处理 `InterruptedException`，例如添加 `Thread.currentThread().interrupt()` 到可能发生中断的地方，然后在 `catch` 块里检查 `InterruptedException`。

CompletableFuture.allOf(futures.toArray(new CompletableFuture))
    .whenComplete((result, exc) -> {
        if (exc instanceof InterruptedException) {
            Thread.currentThread().interrupt();
        }
    })
    .join();

2. **只阻塞特定异常**：如果你只想等待那些成功的未来，可以使用 `.exceptionally()` 方法捕获异常，或者使用 `.thenApplyVoid(null)` 来忽略结果，只关注完成情况。

3. **使用 try-with-resources** 或者显式关闭 `Futures`：确保每个 `CompletableFuture` 在不再需要时被正确地取消或关闭，以防止意外的长时间等待。

try (var future = ...; var anotherFuture = ...) {
    CompletableFuture.allOf(future, anotherFuture)
        .whenComplete((result, exc) -> handleCompletion(exc))
        .get();
}

4. **使用 `.get(long timeout, TimeUnit unit)`**：设置一个超时时间，这样如果在未来一定时间内没有完成，会抛出 `TimeoutException` 而不是无限等待。

记住，在实际应用中，最好设计程序能够优雅地处理异步任务可能出现的问题，而不是简单依赖于无限等待。