登录
首页 >  文章 >  java教程

Java线程池与ExecutorService使用教程

时间:2026-01-25 09:57:38 476浏览 收藏

怎么入门文章编程?需要学习哪些知识点?这是新手们刚接触编程时常见的问题;下面golang学习网就来给大家整理分享一些知识点,希望能够给初学者一些帮助。本篇文章就来介绍《Java线程池管理与ExecutorService使用详解》,涉及到,有需要的可以收藏一下

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

在Java里ExecutorService如何管理线程池_Java并发工具类说明

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(),并在可中断点(如 sleepwaitBlockingQueue.take())抛出 InterruptedException
  • 典型漏处理:
    while (running) {
        processOneTask(); // 如果这里不检查中断,shutdownNow 无效
    }

如何避免线程池泄漏(忘记关闭或重复创建)

线程池是重量级资源,泄漏表现为 CPU 占用高、GC 频繁、应用无法退出。

  • 全局线程池建议声明为 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") 注册,交由容器管理生命周期
线程池不是“用了就扔”的工具,核心在于理解它的状态流转和中断契约——很多问题不是 API 不好用,而是任务本身没配合中断语义。

好了,本文到此结束,带大家了解了《Java线程池与ExecutorService使用教程》,希望本文对你有所帮助!关注golang学习网公众号,给大家分享更多文章知识!

前往漫画官网入口并下载 ➜
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>