newFixedThreadPool创建固定大小线程池,队列无界易OOM;newCachedThreadPool线程数无上限,高并发易打爆系统;应优先手动构造ThreadPoolExecutor。

ExecutorService 创建线程池时,newFixedThreadPool 和 newCachedThreadPool 的行为差异
两者都返回 ExecutorService,但底层策略完全不同,选错会导致资源耗尽或响应延迟。
-
newFixedThreadPool(n):创建固定大小的线程池,所有任务排队等待空闲线程;队列无界(用的是LinkedBlockingQueue),任务持续提交可能引发 OOM -
newCachedThreadPool():线程空闲 60 秒后回收,需要时新建线程;最大线程数为Integer.MAX_VALUE,突发高并发容易打爆系统 - 更安全的做法是用
ThreadPoolExecutor构造器手动指定:核心线程数、最大线程数、空闲超时、阻塞队列(推荐ArrayBlockingQueue或带拒绝策略的SynchronousQueue)
submit() 和 execute() 在异常处理上的关键区别
这是最容易踩坑的地方——不是所有异常都会被你看到。
-
execute(Runnable):异常会直接抛到线程的UncaughtExceptionHandler,如果没设置,默认打印堆栈后静默吞掉 -
submit(Runnable)或submit(Callable):异常被包装进Future,**必须调用get()才会抛出**;不调用就永远不会暴露 - 常见错误写法:
executor.submit(() -> { throw new RuntimeException("boom"); }); // 这个异常永远不会被发现 - 正确做法:要么用
execute+ 自定义ThreadFactory设置异常处理器,要么对每个Future显式调用get()(注意加超时)
shutdown() 和 shutdownNow() 的实际终止效果
它们都不保证立即停止线程,只是改变线程池状态并尝试中断正在执行的任务。
-
shutdown():不再接受新任务,等已提交任务(包括队列中未开始的)执行完再停;不会中断正在运行的线程 -
shutdownNow():尝试中断所有线程(调用Thread.interrupt()),返回“未开始执行”的任务列表;已运行的任务是否停止,取决于它是否响应中断 - 真正安全关闭需配合:任务内部定期检查
Thread.currentThread().isInterrupted(),并在可中断点(如sleep、wait、BlockingQueue.take())抛出InterruptedException - 典型漏处理:
while (running) { processOneTask(); // 如果这里不检查中断,shutdownNow 无效 }
如何避免线程池泄漏(忘记关闭或重复创建)
线程池是重量级资源,泄漏表现为 CPU 占用高、GC 频繁、应用无法退出。
立即学习“Java免费学习笔记(深入)”;
- 全局线程池建议声明为
static final,复用而非每次 new;尤其避免在循环或高频方法里调用Executors.newXXX - 使用
try-with-resources不适用——ExecutorService没实现AutoCloseable(Java 19 才加入预览版) - 可靠关闭模式:
executor.shutdown(); try { if (!executor.awaitTermination(30, TimeUnit.SECONDS)) { executor.shutdownNow(); } } catch (InterruptedException e) { executor.shutdownNow(); Thread.currentThread().interrupt(); } - Spring 环境下优先用
@Bean(destroyMethod = "shutdown")注册,交由容器管理生命周期










