completablefuture 生产环境应使用自定义线程池，推荐在 supplyasync、thenapplyasync 等带 async 后缀的方法中显式传入 executor；避免使用无参重载以防回退到 forkjoinpool.commonpool()；不建议全局替换默认池，可封装工具类统一管理。
CompletableFuture 默认使用 ForkJoinPool.commonPool()，但生产环境通常需要自定义线程池来避免阻塞公共池、控制并发、隔离任务类型或统一管理生命周期。指定方式主要有两种：显式传入 Executor 参数，或全局替换默认池（不推荐）。
方式一：构造/执行方法中传入 Executor（推荐）
绝大多数 CompletableFuture 的异步操作方法都提供带 Executor 参数的重载，这是最直接、最可控的方式：
CompletableFuture.supplyAsync(Supplier, Executor)CompletableFuture.runAsync(Runnable, Executor)-
thenApplyAsync、thenAcceptAsync、thenComposeAsync等链式方法（注意带Async后缀的才支持传 Executor）
示例：
ExecutorService customPool = Executors.newFixedThreadPool(8,
new ThreadFactoryBuilder().setNameFormat("cf-task-%d").build());
CompletableFuture<string> future = CompletableFuture
.supplyAsync(() -> doHeavyWork(), customPool)
.thenApplyAsync(result -> process(result), customPool)
.exceptionally(throwable -> "fallback");
</string>
方式二：避免误用无参方法（关键细节）
像 supplyAsync(Supplier)、thenApplyAsync(Function) 这类**无参重载**，会自动使用 commonPool()，即使你前面用了自定义池，后续链式调用若没显式指定，就可能“掉回”公共池。务必检查每一步是否加了 Async 后缀并传入 Executor。
常见误区：
- 写成
future.thenApply(...)→ 同步执行，在当前线程跑（不是异步！） - 写成
future.thenApplyAsync(...)但没传 Executor → 走commonPool() - 混合使用：前几步用自定义池，后几步漏传 → 线程池混用，难以监控和调优
方式三：谨慎考虑全局替换（仅限特殊场景）
可通过 JVM 参数 -Djava.util.concurrent.ForkJoinPool.common.parallelism=N 调整 commonPool 并发度，但不能完全替换为自定义线程池。JDK 不提供设置 commonPool 为任意 Executor 的公开 API（内部有 hack 方式，但极不推荐，破坏封装且版本兼容性差）。
真正需要“全局默认”的场景，建议封装工具类：
public class CF {
private static final Executor EXEC = ... // 你的线程池
public static <t> CompletableFuture<t> supply(T supplier) {
return CompletableFuture.supplyAsync(supplier, EXEC);
}
public static <t> CompletableFuture<r> thenApplyAsync(
CompletableFuture<t> f, Function<t> fn) {
return f.thenApplyAsync(fn, EXEC);
}
}
</t></t></r></t></t></t>
线程池选型与注意事项
自定义池不是越大越好，需结合任务类型选择：
-
CPU 密集型：线程数 ≈ CPU 核心数（如
newFixedThreadPool(Runtime.getRuntime().availableProcessors())） - IO 密集型（含远程调用、DB 查询）：可适当放大（如 2–4 倍核数），但需配合超时和熔断，防止线程耗尽
-
务必命名线程：便于日志排查（如用 Guava 的
ThreadFactoryBuilder或 Apache Commons 的BasicThreadFactory） -
记得 shutdown：应用停机时调用
customPool.shutdown()+awaitTermination()，避免 JVM 无法退出
不复杂但容易忽略。
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
