前言在Java 8之前我们使用Future来获取异步计算的结果但Future的局限性非常明显——它只是一个结果的容器我们无法对其结果进行链式处理、组合多个异步任务或者优雅地处理异常。直到Java 8引入了CompletableFuture这一切才发生了改变。CompletableFuture是Java并发编程中的一个里程碑式的API它不仅实现了Future接口还实现了CompletionStage接口提供了丰富的链式调用、组合、异常处理等能力让我们能够以声明式的方式编写复杂的异步逻辑。本文将从基础概念到高级用法带你全面掌握CompletableFuture的核心知识。一、CompletableFuture 概述1.1 什么是 CompletableFutureCompletableFuture是Java 8引入的一个类它同时实现了Future和CompletionStage两个接口Future接口提供了获取异步计算结果的基本能力CompletionStage接口提供了大约50种方法用于链式组合多个异步任务CompletableFuture的核心思想是将异步计算的结果看作一个阶段Stage每个阶段完成后可以触发下一个阶段形成一条异步流水线。1.2 为什么需要 CompletableFuture传统Future的痛点无法手动完成Future只能由执行任务的线程完成调用方无法主动设置结果无法链式调用获取结果后无法直接传递给下一个异步任务无法组合多个Future多个异步任务之间的依赖关系难以表达异常处理困难异步任务中的异常难以优雅捕获和处理阻塞式获取结果get()方法会阻塞直到结果返回CompletableFuture完美解决了这些问题。二、核心 API 详解2.1 创建 CompletableFuture方式一使用 completedFuture 创建已完成的 Future// 创建一个已经完成的CompletableFuture值为HelloCompletableFutureStringfutureCompletableFuture.completedFuture(Hello);这在测试或者需要立即返回结果的场景中非常有用。方式二使用 supplyAsync 异步执行有返回值的任务CompletableFutureStringfutureCompletableFuture.supplyAsync(()-{// 模拟耗时操作try{Thread.sleep(1000);}catch(InterruptedExceptione){e.printStackTrace();}return异步计算结果;});supplyAsync接受一个Supplier函数式接口有返回值。方式三使用 runAsync 异步执行无返回值的任务CompletableFutureVoidfutureCompletableFuture.runAsync(()-{// 模拟耗时操作无返回值try{Thread.sleep(1000);}catch(InterruptedExceptione){e.printStackTrace();}System.out.println(异步任务执行完成);});runAsync接受一个Runnable函数式接口无返回值。方式四手动创建并完成CompletableFutureStringfuturenewCompletableFuture();// 在某个线程中手动完成newThread(()-{try{Thread.sleep(1000);future.complete(手动设置的结果);}catch(InterruptedExceptione){future.completeExceptionally(e);}}).start();这是CompletableFuture最强大的特性之一——你可以在任何时间、任何线程中手动完成它。2.2 线程池的选择默认情况下supplyAsync和runAsync会使用**ForkJoinPool.commonPool()**作为线程池。这个公共线程池的大小默认为CPU核心数-1。但我们也可以指定自己的线程池ExecutorServiceexecutorExecutors.newFixedThreadPool(10);CompletableFutureStringfutureCompletableFuture.supplyAsync(()-{return使用自定义线程池;},executor);最佳实践对于IO密集型任务建议使用自定义线程池避免耗尽公共线程池。2.3 链式调用处理异步结果CompletableFuture最强大的地方在于它的链式调用能力。thenApply转换结果CompletableFutureStringfutureCompletableFuture.supplyAsync(()-Hello).thenApply(s-s World).thenApply(String::toUpperCase);// 输出: HELLO WORLDSystem.out.println(future.get());thenApply接受一个Function函数式接口将上一阶段的结果进行转换返回新的结果。thenAccept消费结果CompletableFuture.supplyAsync(()-Hello).thenApply(s-s World).thenAccept(System.out::println);// 输出: Hello WorldthenAccept接受一个Consumer函数式接口消费上一阶段的结果无返回值。thenRun执行后续操作CompletableFuture.supplyAsync(()-{System.out.println(执行任务);returnresult;}).thenRun(()-{System.out.println(任务完成后的收尾工作);});thenRun接受一个Runnable不关心上一阶段的结果只是在完成后执行某个动作。异步版本的链式调用上面的方法都有对应的异步版本thenApplyAsync、thenAcceptAsync、thenRunAsync。它们的区别是同步版本不带Async使用与上一阶段相同的线程执行异步版本带Async重新提交到线程池中执行CompletableFuture.supplyAsync(()-{System.out.println(supplyAsync: Thread.currentThread().getName());returnHello;}).thenApply(s-{System.out.println(thenApply: Thread.currentThread().getName());returns World;}).thenApplyAsync(s-{System.out.println(thenApplyAsync: Thread.currentThread().getName());returns.toUpperCase();});2.4 组合多个 CompletableFuturethenCompose扁平化组合当你有一个返回CompletableFuture的函数时使用thenApply会导致嵌套的CompletableFuture// 错误示范嵌套的CompletableFutureCompletableFutureCompletableFutureStringfutureCompletableFuture.supplyAsync(()-Hello).thenApply(s-getUserAsync(s));这时候应该使用thenCompose它类似于Stream的flatMap// 正确示范扁平化组合CompletableFutureStringfutureCompletableFuture.supplyAsync(()-Hello).thenCompose(s-getUserAsync(s));thenApply vs thenCompose 的区别thenApplymap操作返回普通值thenComposeflatMap操作返回CompletableFuturethenCombine组合两个Future的结果CompletableFutureStringfuture1CompletableFuture.supplyAsync(()-Hello);CompletableFutureStringfuture2CompletableFuture.supplyAsync(()-World);CompletableFutureStringcombinedfuture1.thenCombine(future2,(s1,s2)-s1 s2);// 输出: Hello WorldSystem.out.println(combined.get());thenCombine等待两个Future都完成后用BiFunction组合它们的结果。allOf等待所有Future完成CompletableFutureStringfuture1CompletableFuture.supplyAsync(()-结果1);CompletableFutureStringfuture2CompletableFuture.supplyAsync(()-结果2);CompletableFutureStringfuture3CompletableFuture.supplyAsync(()-结果3);CompletableFutureVoidallFuturesCompletableFuture.allOf(future1,future2,future3);// 等待所有任务完成allFutures.get();// 然后分别获取结果System.out.println(future1.get());System.out.println(future2.get());System.out.println(future3.get());注意allOf返回的是CompletableFutureVoid它不返回所有结果的集合只是表示所有任务都完成了。如果需要收集所有结果可以这样做ListCompletableFutureStringfuturesArrays.asList(future1,future2,future3);CompletableFutureListStringallResultsCompletableFuture.allOf(futures.toArray(newCompletableFuture[0])).thenApply(v-futures.stream().map(CompletableFuture::join).collect(Collectors.toList()));anyOf任意一个Future完成即可CompletableFutureStringfuture1CompletableFuture.supplyAsync(()-{sleep(100);return快速结果;});CompletableFutureStringfuture2CompletableFuture.supplyAsync(()-{sleep(1000);return慢速结果;});CompletableFutureObjectanyFutureCompletableFuture.anyOf(future1,future2);// 输出: 快速结果谁先完成返回谁System.out.println(anyFuture.get());2.5 异常处理CompletableFuture提供了三种异常处理方式。exceptionally捕获异常并返回默认值CompletableFutureStringfutureCompletableFuture.supplyAsync(()-{thrownewRuntimeException(计算出错了);}).exceptionally(ex-{System.out.println(捕获异常: ex.getMessage());return默认值;});// 输出: 默认值System.out.println(future.get());exceptionally类似于catch块当上面的任何阶段抛出异常时都会进入这里。handle无论成功还是异常都执行CompletableFutureStringfutureCompletableFuture.supplyAsync(()-{thrownewRuntimeException(出错了);}).handle((result,ex)-{if(ex!null){System.out.println(发生异常: ex.getMessage());return恢复值;}returnresult;});handle类似于try-catch-finally中的finally无论成功还是失败都会执行。whenComplete只做副作用不改变结果CompletableFutureStringfutureCompletableFuture.supplyAsync(()-{return正常结果;}).whenComplete((result,ex)-{if(ex!null){System.out.println(记录异常日志: ex.getMessage());}else{System.out.println(记录成功日志结果是: result);}});whenComplete不改变结果只是在完成时执行一些副作用操作如日志记录。三、实战案例3.1 案例一电商商品详情页聚合假设我们要开发一个电商商品详情页需要并行获取以下信息商品基本信息商品价格商品库存商品评价使用CompletableFuture可以轻松实现并行获取publicProductDetailgetProductDetail(LongproductId){// 并行获取各个信息CompletableFutureProductInfoproductInfoFutureCompletableFuture.supplyAsync(()-productService.getProductInfo(productId));CompletableFuturePriceInfopriceInfoFutureCompletableFuture.supplyAsync(()-priceService.getPriceInfo(productId));CompletableFutureStockInfostockInfoFutureCompletableFuture.supplyAsync(()-stockService.getStockInfo(productId));CompletableFutureReviewInforeviewInfoFutureCompletableFuture.supplyAsync(()-reviewService.getReviewInfo(productId));// 等待所有任务完成并组装结果returnCompletableFuture.allOf(productInfoFuture,priceInfoFuture,stockInfoFuture,reviewInfoFuture).thenApply(v-{ProductDetaildetailnewProductDetail();detail.setProductInfo(productInfoFuture.join());detail.setPriceInfo(priceInfoFuture.join());detail.setStockInfo(stockInfoFuture.join());detail.setReviewInfo(reviewInfoFuture.join());returndetail;}).join();}这样四个接口调用是并行执行的总耗时取决于最慢的那个而不是四个的总和。3.2 案例二多级依赖的异步流水线假设我们有一个复杂的业务流程先查询用户信息根据用户信息查询用户的订单根据订单查询订单详情最后组装完整的用户订单视图publicUserOrderViewgetUserOrderView(LonguserId){returnCompletableFuture.supplyAsync(()-userService.getUser(userId)).thenCompose(user-orderService.getOrdersAsync(user.getId())).thenCompose(orders-orderDetailService.getDetailsAsync(orders)).thenApply(details-{UserOrderViewviewnewUserOrderView();view.setOrderDetails(details);returnview;}).exceptionally(ex-{log.error(获取用户订单视图失败,ex);returnnewUserOrderView();// 返回空视图}).join();}使用thenCompose可以优雅地表达多级依赖关系。3.3 案例三超时控制在实际项目中我们经常需要给异步任务设置超时时间避免无限等待。publicTCompletableFutureTwithTimeout(CompletableFutureTfuture,longtimeout,TimeUnitunit){// 创建一个超时用的CompletableFutureCompletableFutureTtimeoutFuturenewCompletableFuture();// 定时任务超时后完成timeoutFuture并抛出异常ScheduledExecutorServiceschedulerExecutors.newScheduledThreadPool(1);scheduler.schedule(()-timeoutFuture.completeExceptionally(newTimeoutException(任务超时)),timeout,unit);// 谁先完成用谁的结果returnCompletableFuture.anyOf(future,timeoutFuture).thenApply(o-(T)o).whenComplete((result,ex)-scheduler.shutdown());}使用方法CompletableFutureStringfutureCompletableFuture.supplyAsync(()-{// 模拟耗时操作sleep(5000);return结果;});// 设置3秒超时StringresultwithTimeout(future,3,TimeUnit.SECONDS).exceptionally(ex-超时默认值).get();四、最佳实践与注意事项4.1 get() vs join()两者都是获取结果的方法区别在于方法异常类型是否受检异常get()ExecutionException是需要try-catchjoin()CompletionException否运行时异常推荐在流式调用中使用join()因为它不需要强制捕获异常。4.2 合理选择线程池不要所有场景都用默认的ForkJoinPoolCPU密集型任务可以使用默认的ForkJoinPool.commonPool()IO密集型任务必须使用自定义线程池线程数可以设置得大一些业务隔离不同业务使用不同的线程池避免互相影响4.3 异常处理的最佳位置建议在整个链路的最后统一处理异常// 推荐最后统一处理异常CompletableFuture.supplyAsync(()-step1()).thenApply(r-step2(r)).thenApply(r-step3(r)).exceptionally(ex-{// 统一处理所有异常log.error(任务执行失败,ex);returndefaultValue;});而不是每个步骤都处理异常那样会让代码变得混乱。4.4 避免 CompletableFuture 泄露如果创建了CompletableFuture但忘记complete它会导致等待它的线程永远阻塞// 危险如果某些分支没有complete会导致永久阻塞CompletableFutureStringfuturenewCompletableFuture();if(condition){future.complete(success);}// else分支没有complete建议总是确保所有分支都能complete或者设置超时机制。4.5 谨慎使用 thenApply 等同步方法thenApply、thenAccept、thenRun这些不带Async的方法会在上一个任务的线程中执行。如果上一个任务是在IO线程中执行的而你的thenApply里又有耗时操作可能会阻塞IO线程。建议如果后续操作比较耗时使用带Async的版本。五、总结CompletableFuture是Java并发编程的一大利器让我们回顾一下它的核心能力灵活的创建方式supplyAsync、runAsync、手动complete强大的链式调用thenApply、thenAccept、thenRun丰富的组合能力thenCompose、thenCombine、allOf、anyOf优雅的异常处理exceptionally、handle、whenComplete掌握了CompletableFuture你就能写出更加优雅、高效的异步代码。但也要注意合理使用线程池、做好异常处理、避免常见的陷阱。在实际项目中CompletableFuture常用于接口聚合并行调用多个服务异步化处理提升响应速度复杂的业务流程编排超时控制、降级容错希望这篇文章能帮助你深入理解CompletableFuture在并发编程的道路上更进一步参考资料Java官方文档CompletableFutureJava官方文档CompletionStage《Java并发编程实战》如果你觉得这篇文章对你有帮助欢迎点赞、收藏、关注有任何问题也可以在评论区留言讨论。
