首页CompletableFuture的join方法

CompletableFuture的join方法

时间: 2025-06-11 08:34:42 浏览: 12

### CompletableFuture的join方法使用说明 `CompletableFuture`的`join()`方法用于获取异步任务的结果。与`get()`方法类似，`join()`方法也会阻塞当前线程直到任务完成，但它不会抛出异常，而是将异常包装为`CompletionException`并向上抛出[^3]。 #### 方法特点 - 如果任务成功完成，则返回结果。 - 如果任务失败，则抛出一个包含原始异常的`CompletionException`。 - `join()`方法是非检查异常的，因此不需要在代码中显式捕获或声明异常。 #### 示例代码以下是一个使用`join()`方法的示例： ```java import java.util.concurrent.CompletableFuture; public class CompletableFutureJoinExample { public static void main(String[] args) { // 创建一个CompletableFuture对象，定义异步任务 CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> { System.out.println("Executing async task..."); if (Math.random() > 0.5) { throw new RuntimeException("Task failed"); } return "Success"; }); try { // 使用join()方法获取结果 String result = future.join(); System.out.println("Result: " + result); } catch (CompletionException e) { System.out.println("Caught exception: " + e.getCause().getMessage()); } } } ``` #### 详细解释在上述代码中： - 异步任务通过`supplyAsync`创建，模拟了一个可能失败的任务。 - 调用`join()`方法时，如果任务成功完成，则输出结果；如果任务失败，则捕获`CompletionException`并输出原始异常信息。 #### 注意事项 - `join()`方法虽然简化了异常处理，但在高并发场景下，仍然需要小心处理可能的异常情况。 - 如果需要设置超时时间，可以结合`orTimeout`方法使用[^4]。 ###

阅读全文