CompletableFuture.runAsync执行耗时

### 使用 `CompletableFuture.runAsync` 执行长时间运行任务的最佳实践

当使用 `CompletableFuture.runAsync` 来执行可能耗时较长的操作时，有几个最佳实践可以帮助提高程序的效率和可靠性。

#### 设置自定义线程池
默认情况下，`runAsync` 方法会使用公共的 ForkJoinPool.commonPool() 线程池来执行异步操作。然而，在处理大量或长时间运行的任务时，建议创建专用的线程池以避免阻塞其他任务：

ExecutorService customThreadPool = Executors.newFixedThreadPool(10);
CompletableFuture<Void> futureWithCustomPool =
    CompletableFuture.runAsync(() -> {
        // 长时间运行的任务代码...
    }, customThreadPool);

通过这种方式可以更好地控制并发度以及资源分配[^1]。

#### 超时机制
为了防止某些异常情况下的无限期等待，可以在调用处设置超时期限。如果超过指定的时间未完成，则抛出 TimeoutException 并取消该 Future 对象:

try {
    CompletableFuture<Void> longRunningTask = 
        CompletableFuture.runAsync(/*...*/);

    // 尝试获取结果，最多等待5秒
    Void result = longRunningTask.get(5, TimeUnit.SECONDS); 

} catch (TimeoutException e) {
    // 处理超时错误
}

这有助于及时发现潜在问题并采取相应措施[^2]。

#### 错误恢复策略
对于可能出现失败的情况，应该考虑加入重试逻辑或其他形式的容错方案。例如利用 exceptionally 或 handle 方法来进行优雅降级：

CompletableFuture<Void> resilientOperation =
    CompletableFuture.runAsync(() -> /* ... */)
                      .exceptionally(ex -> {
                          log.error("An error occurred", ex);
                          return null;
                      });

这样即使遇到不可预见的问题也能保持系统的稳定性和可用性[^3]。

#### 组合多个异步任务
如果有多个相互独立但又需要一起协调工作的子任务，那么可以通过 thenCompose、allOf 和 anyOf 这样的组合器将它们串联起来形成更复杂的流程图结构。比如下面的例子展示了如何同时发起两个请求并将最终的结果汇总在一起：

public PriceResult comparePricesConcurrently(String productId){
    
    CompletableFuture<PriceInfo> priceQuery = 
        CompletableFuture.supplyAsync(() ->
            queryExternalServiceForPrice(productId));

    CompletableFuture<PromotionDetails> promoCheck = 
        CompletableFuture.supplyAsync(() ->
            checkPromotionsApplicableToProduct(productId));
        
    return CompletableFuture.allOf(priceQuery,promoCheck).thenApply(v->
         combineResultsIntoFinalOutput(
             priceQuery.join(),promoCheck.join())
     ).join();
}

这种方法不仅提高了整体吞吐量还简化了业务逻辑之间的依赖关系管理[^4]。