java自定义threadpoolexecutor需精准配置7个核心参数：corepoolsize、maximumpoolsize、keepalivetime、workqueue、threadfactory、handler及拒绝策略，避免使用executors快捷方法以防oom。
Java 中使用 ThreadPoolExecutor 自定义线程池，关键在于理解七个核心参数的含义和协同关系，而不是简单套用构造方法。
核心参数含义与设置逻辑
ThreadPoolExecutor 最完整的构造方法有 7 个参数：
-
corePoolSize：核心线程数。线程池中常驻的最小线程数量，即使空闲也不会被回收（除非设置了
allowCoreThreadTimeOut(true)） - maximumPoolSize：最大线程数。线程池允许创建的最大线程总数，只有当任务队列满且当前线程数
-
keepAliveTime：非核心线程空闲存活时间。超过
corePoolSize的线程，在空闲超过此时间后会被终止 -
unit：
keepAliveTime的时间单位，如TimeUnit.SECONDS -
workQueue：任务阻塞队列。用于存放等待执行的
Runnable任务，常见选择：LinkedBlockingQueue（无界）、ArrayBlockingQueue（有界）、SynchronousQueue（不存储，直接移交） - threadFactory：线程工厂。用于创建新线程，可自定义命名、设置守护线程、指定线程组等
-
handler：拒绝策略。当线程池关闭或任务无法被接收（队列满 + 线程数已达最大）时的处理方式，如
AbortPolicy（抛异常）、CallerRunsPolicy（由调用线程执行）等
典型场景下的参数搭配建议
参数不是孤立设定的，需结合业务类型权衡：
-
CPU 密集型任务（如大量计算、加解密）：线程数不宜过多，一般设为
corePoolSize = maximumPoolSize = CPU 核数 + 1；队列宜小或用SynchronousQueue，避免任务积压导致上下文切换开销 -
IO 密集型任务（如数据库查询、HTTP 调用）：线程可适当增多，常见公式：
corePoolSize ≈ CPU 核数 × (1 + 平均等待时间 / 平均工作时间)；推荐使用有界队列（如ArrayBlockingQueue），配合合理的拒绝策略防止 OOM -
突发流量场景：可设较小
corePoolSize、较大maximumPoolSize和中等大小有界队列，再配CallerRunsPolicy让调用方降速，实现柔性保护
一个安全可控的自定义示例
以下是一个生产可用的线程池构建片段（含命名、拒绝日志、资源释放）：
ThreadFactory namedFactory = new ThreadFactoryBuilder()
.setNameFormat("biz-task-pool-%d")
.setDaemon(false)
.build();
BlockingQueue<runnable> queue = new ArrayBlockingQueue(1024);
RejectedExecutionHandler handler = (r, executor) -> {
log.warn("Task {} rejected from {}", r, executor);
throw new RuntimeException("Task rejected, please check system load");
};
ThreadPoolExecutor executor = new ThreadPoolExecutor(
4, // corePoolSize
16, // maximumPoolSize
60L, // keepAliveTime
TimeUnit.SECONDS,
queue,
namedFactory,
handler
);
// 可选：预启动核心线程，避免首次调用延迟
executor.prestartAllCoreThreads();
</runnable>
注意：线程池应作为单例长期持有，避免频繁创建销毁；使用完毕后记得调用 shutdown() 或 shutdownNow() 释放资源。
常见误区提醒
- 不要用
Executors.newFixedThreadPool(10)等快捷方法——它们内部使用了无界队列，高并发下极易 OOM -
corePoolSize = 0是合法的，适合纯异步提交+快速响应场景（如 Netty 事件循环），但需确保队列和拒绝策略能兜底 - 修改
corePoolSize或maximumPoolSize可通过setCorePoolSize()/setMaximumPoolSize()动态调整，但要注意线程启停时机 - 务必为线程池命名，便于排查问题时从线程堆栈识别来源
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
