completablefuture thenRunAsyn

### CompletableFuture 中 `thenRunAsync` 方法的用法 `thenRunAsync` 是 `CompletableFuture` 的一个重要方法，用于在前一个任务完成后执行一个新的无返回值的任务（即 `Runnable` 类型）。此方法支持异步编程模型，并允许指定自定义线程池来运行后续任务。 以下是关于 `thenRunAsync` 的具体说明及其示例： #### 方法签名 `public CompletableFuture<Void> thenRunAsync(Runnable action)` `public CompletableFuture<Void> thenRunAsync(Runnable action, Executor executor)` - **参数解释**： - `action`: 表示要执行的无返回值的操作。 - `executor`: 可选参数，表示用来执行该操作的线程池。如果不提供，则默认使用 ForkJoinPool.commonPool()。 #### 使用场景 当某个异步任务完成之后，需要立即启动另一个不依赖于上一任务结果的新任务时，可以使用 `thenRunAsync`。它不会阻塞主线程，而是通过异步方式继续处理逻辑[^1]。 #### 示例代码 下面是一个简单的例子展示如何利用 `thenRunAsync` 来实现链式调用中的独立动作触发： ```java import java.util.concurrent.CompletableFuture; import java.util.concurrent.ExecutionException; public class ThenRunAsyncExample { public static void main(String[] args) throws ExecutionException, InterruptedException { // 创建第一个 Completable Future 实例并模拟耗时计算 CompletableFuture<String> cf = CompletableFuture.supplyAsync(() -> { System.out.println("Supplying result..."); try { Thread.sleep(2000); } catch (InterruptedException e) {} return "Result"; }); // 当上面的结果准备好后，执行额外的动作而无需关心其实际数据 cf.thenRunAsync(() -> { System.out.println("Executing follow-up task without needing the previous value."); }).join(); // 阻塞直到整个流程结束 // 如果希望定制化线程环境可如下设置ExecutorService作为第二个参数传入 /*cf.thenRunAsync(() -> {}, myCustomThreadPool);*/ System.out.println("Main program continues execution here..."); } } ``` 上述程序展示了基本的工作流：先有供给阶段生成某些输出；随后，在不影响主进程的前提下安排另一项仅需知晓前者已成功即可开展的小型作业。 #### 注意事项 尽管 `CompletableFuture` 功能强大，但在涉及大量回调链条的情况下可能会降低代码清晰度[^2]。此外需要注意的是，如果尝试取消基于长时间运行I/O或其他可能被挂起等待资源释放之类情况下的实例，默认行为并不会真正终止底层正在工作的线程——这可能导致潜在泄漏或者性能瓶颈问题存在风险[^3]。