CompletableFuture 应使用自定义线程池替代默认 commonPool，通过 supplyAsync 等 Async 方法显式传入 Executor 实现；IO 任务需独立线程池，避免阻塞 commonPool；推荐封装工具类统一管理并注意生命周期。
CompletableFuture 默认使用 ForkJoinPool.commonPool()，但生产环境通常需要可控的自定义线程池来避免资源争用、实现线程隔离或适配业务负载。关键不是“能不能换”，而是“在哪换”和“怎么换才安全有效”。
在异步方法调用时指定线程池
CompletableFuture 提供了以 Async 结尾的一系列方法（如 supplyAsync、runAsync、thenApplyAsync 等），它们都支持传入 Executor 参数——这就是插入自定义线程池的入口。
示例：
ExecutorService customPool = Executors.newFixedThreadPool(8);
CompletableFuture<String> future = CompletableFuture
.supplyAsync(() -> fetchDataFromDB(), customPool) // 第一步用自定义池
.thenApplyAsync(data -> process(data), customPool) // 后续异步步骤也显式指定
.thenAcceptAsync(result -> logResult(result), customPool);
⚠️ 注意：如果不传 Executor，thenApplyAsync 等会回落到 commonPool，容易造成混用。建议所有 Async 方法都显式传入同一池（或封装成工具方法统一管理）。
立即学习“Java免费学习笔记（深入）”；
避免 commonPool 被耗尽或阻塞
ForkJoinPool.commonPool() 是 JVM 全局共享的，且默认并行度为 CPU 核数减一。一旦有慢 IO 或阻塞操作（如数据库查询、HTTP 调用）跑在上面，极易拖垮整个应用的异步任务调度。
正确做法：
- IO 密集型任务（DB、RPC、文件读写）必须使用独立的、带足够队列容量的线程池（如
newCachedThreadPool或newFixedThreadPool+ 有界队列） - CPU 密集型计算可谨慎复用
commonPool，但更推荐统一走自定义池便于监控和调优 - 不要在自定义线程池中执行
join()或get()等阻塞操作，否则会浪费线程
线程池选择与配置建议
根据任务特征选池，不是越“高级”越好：
-
短小、无阻塞的纯计算：可用
newFixedThreadPool(n)，n ≈ CPU 核数 -
含 IO 或不确定耗时的任务：推荐
newCachedThreadPool()（注意未限制最大线程数，需配合ThreadFactory命名+监控），或更稳妥的newFixedThreadPool+ 较大核心数 +LinkedBlockingQueue -
需拒绝策略/熔断：用
new ThreadPoolExecutor(...)自定义，比如拒绝时抛异常或降级
示例（带命名与拒绝策略）：
ThreadFactory namedFactory = new ThreadFactoryBuilder()
.setNameFormat("cf-io-pool-%d")
.build();
ExecutorService ioPool = new ThreadPoolExecutor(
4, 16,
60L, TimeUnit.SECONDS,
new LinkedBlockingQueue<>(1000),
namedFactory,
new ThreadPoolExecutor.CallerRunsPolicy() // 拒绝时由调用线程执行
);
统一管理：封装 Async 工具类
重复传同一个 Executor 易出错，可封装静态工具类提升一致性：
public class CF {
private static final Executor IO_POOL = ...; // 上面定义的 ioPool
public static <T> CompletableFuture<T> supply(IOSupplier<T> supplier) {
return CompletableFuture.supplyAsync(supplier::get, IO_POOL);
}
public static <T, R> CompletableFuture<R> thenApplyAsync(
CompletableFuture<T> future, Function<T, R> fn) {
return future.thenApplyAsync(fn, IO_POOL);
}
}
// 使用
CompletableFuture<String> f = CF.supply(() -> callHttp());
这样既避免漏传，又便于后续统一替换线程池或加日志埋点。
不复杂但容易忽略：线程池生命周期要和应用一致，记得在应用关闭时调用 shutdown() 和 awaitTermination()。
