使用自定义线程池可避免阻塞ForkJoinPool公共线程池，隔离IO与CPU任务，提升系统稳定性；通过ThreadPoolExecutor显式创建线程池，结合CompletableFuture的Async方法指定执行器，实现资源精细控制，并合理配置线程数与队列，防止内存溢出。
在Java中，CompletableFuture 是实现异步编程的重要工具，它允许你以非阻塞方式执行任务并组合多个异步操作。结合自定义线程池使用，可以更好地控制资源、避免阻塞公共ForkJoinPool，提升性能和稳定性。
为什么要结合线程池使用
CompletableFuture 默认使用 ForkJoinPool.commonPool() 来执行异步任务。这个公共线程池是JVM全局共享的，如果某个耗时任务或阻塞操作占用了线程，可能会影响其他使用该池的模块。
通过指定自定义线程池，你可以：
- 隔离IO密集型与CPU密集型任务
- 避免阻塞公共线程池
- 更精确地控制线程数量和行为
创建自定义线程池
推荐使用 ThreadPoolExecutor 显式创建线程池，便于监控和调优。
立即学习“Java免费学习笔记（深入）”；
import java.util.concurrent.ExecutorService;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.TimeUnit;
ExecutorService threadPool = new ThreadPoolExecutor(
4, // 核心线程数
8, // 最大线程数
60L, // 空闲线程存活时间
TimeUnit.SECONDS,
new LinkedBlockingQueue<>(100), // 任务队列
r -> {
Thread t = new Thread(r);
t.setName("custom-thread-" + t.getId());
return t;
}
);
在CompletableFuture中使用线程池
几乎所有以 Async 结尾的方法都支持传入自定义线程池。
示例：异步执行任务并处理结果
CompletableFuture.supplyAsync(() -> {
System.out.println("Task running in: " + Thread.currentThread().getName());
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
return "Hello from async task";
}, threadPool)
.thenApply(result -> {
System.out.println("Processing in: " + Thread.currentThread().getName());
return result.toUpperCase();
})
.thenAccept(finalResult -> System.out.println("Final result: " + finalResult))
.exceptionally(throwable -> {
System.err.println("Error occurred: " + throwable.getMessage());
return null;
});
上面代码中，supplyAsync 和后续的 thenApply 都会在指定的 threadPool 中执行（除非显式切换）。
链式操作中的线程控制
你可以灵活选择每个阶段使用的线程池：
- 不带线程池参数的方法：使用默认公共池
- 带Executor的方法：使用指定线程池
例如，让某些阶段在主线程执行，某些在IO池执行：
CompletableFuturefuture = CompletableFuture .completedFuture("Start") .thenComposeAsync(s -> supplyIoHeavyTask(), ioThreadPool) // IO任务用专用池 .thenApplyAsync(result -> processCpuIntensive(result), cpuThreadPool); // CPU任务换池
注意事项
使用时注意以下几点：
- 不要忘记关闭线程池：threadPool.shutdown() 或 shutdownNow()
- 避免在CompletableFuture中执行长时间阻塞操作而不设置超时
- 根据业务类型合理配置线程池大小（IO密集型可多些线程）
- 慎用无界队列，防止内存溢出
基本上就这些。CompletableFuture + 自定义线程池能让你写出高效且可控的异步代码，关键是根据场景合理分配资源。
