Java Review - 线程池资源一直不被释放案例&源码分析

简介: Java Review - 线程池资源一直不被释放案例&源码分析

概述


在日常开发中为了便于线程的有效复用,经常会用到线程池,然而使用完线程池后如果不调用shutdown关闭线程池,则会导致线程池资源一直不被释放。

下面通过简单的例子来说明该问题。


问题复现


下面通过一个例子说明如果不调用线程池对象的shutdown方法关闭线程池,则当线程池里面的任务执行完毕并且主线程已经退出后,JVM仍然存在。


import java.util.concurrent.*;
/**
 * @author 小工匠
 * @version 1.0
 * @description: TODO
 * @date 2021/11/20 23:33
 * @mark: show me the code , change the world
 */
public class PoolShutDownTest {
    public static void main(String[] args) {
        // 异步执行业务1
        ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(5, 10, 10,
                TimeUnit.MINUTES, new LinkedBlockingDeque<>(100));
        threadPoolExecutor.execute(()->{
            try {
                TimeUnit.SECONDS.sleep(3);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("业务1----模拟业务");
        });
        // 异步执行业务2
         ExecutorService executorService = Executors.newSingleThreadExecutor();
         executorService.execute(()->System.out.println("业务2"));
        // 业务执行完成
        System.out.println("executor over");
    }
}

在如上代码的主线程里面,首先 执行了异步业务, 使用线程池的一个线程执行异步操作,我们期望当主线程与异步业务执行完线程池里面的任务后整个JVM就会退出,但是执行结果却如下所示。


5b1d4d2f2b1b4519bc96433270c59265.png

左上的方块说明JVM进程还没有退出 ,这是什么情况呢?修改代码代码,在方法里面添加调用线程池的shutdown方法的代码。

fafbe47681b6442dbbe06670d08856cf.png


再次执行代码你会发现JVM已经退出了,使用ps -eaf|grep java命令查看,发现Java进程已经不存在了,这说明只有调用了线程池的shutdown方法后,线程池任务执行完毕,线程池资源才会被释放。


源码分析


下面看为何会如此?大家或许还记得守护线程与用户线程,JVM退出的条件是当前不存在用户线程,而线程池默认的ThreadFactory创建的线程是用户线程


0ad01541714147df83bb6f036150c4c5.png


由如上代码可知,线程池默认的ThreadFactory创建的都是用户线程。而线程池里面的核心线程是一直存在的,如果没有任务则会被阻塞,所以线程池里面的用户线程一直存在。而shutdown方法的作用就是让这些核心线程终止.

下面简单看下shutdown的主要代码。

    /**
     * Initiates an orderly shutdown in which previously submitted
     * tasks are executed, but no new tasks will be accepted.
     * Invocation has no additional effect if already shut down.
     *
     * <p>This method does not wait for previously submitted tasks to
     * complete execution.  Use {@link #awaitTermination awaitTermination}
     * to do that.
     *
     * @throws SecurityException {@inheritDoc}
     */
    public void shutdown() {
        final ReentrantLock mainLock = this.mainLock;
        mainLock.lock();
        try {
            checkShutdownAccess();
            // 设置线程池状态为SHUTDOWN
            advanceRunState(SHUTDOWN);
            // 中断所有的空闲工作线程
            interruptIdleWorkers();
            onShutdown(); // hook for ScheduledThreadPoolExecutor
        } finally {
            mainLock.unlock();
        }
        tryTerminate();
    }


这里在shutdown方法里面设置了线程池的状态为SHUTDOWN,并且设置了所有Worker空闲线程(阻塞到队列的take()方法的线程)的中断标志。


a08ece49c4dd483c991c75b2771cf91e.png

/**
     * Transitions runState to given target, or leaves it alone if
     * already at least the given target.
     *
     * @param targetState the desired state, either SHUTDOWN or STOP
     *        (but not TIDYING or TERMINATED -- use tryTerminate for that)
     */
    private void advanceRunState(int targetState) {
        for (;;) {
            int c = ctl.get();
            if (runStateAtLeast(c, targetState) ||
                ctl.compareAndSet(c, ctlOf(targetState, workerCountOf(c))))
                break;
        }
    }

那么下面来看在工作线程Worker里面是不是设置了中断标志,然后它就会退出。

final void runWorker(Worker w) {
        .......
        try {
            while (task != null || (task = getTask()) != null) {
               .......   
        } finally {
             .......
        }
    }
 private Runnable getTask() {
        boolean timedOut = false; // Did the last poll() time out?
        for (;;) {
            ....
            // Check if queue empty only if necessary.
            // 代码1 
            if (rs >= SHUTDOWN && (rs >= STOP || workQueue.isEmpty())) {
                decrementWorkerCount();
                return null;
            }
            try {
               // 代码2
                Runnable r = timed ?
                    workQueue.poll(keepAliveTime, TimeUnit.NANOSECONDS) :
                    workQueue.take();
                if (r != null)
                    return r;
                timedOut = true;
            } catch (InterruptedException retry) {
                timedOut = false;
            }
        }
    }


在如上代码中,在正常情况下如果队列里面没有任务,则工作线程被阻塞到代码(2)等待从工作队列里面获取一个任务。


这时候如果调用线程池的shutdown命令(shutdown命令会中断所有工作线程),则代码(2)会抛出InterruptedException异常而返回,而这个异常被捕捉到了,所以继续执行代码(1),而执行shutdown时设置了线程池的状态为SHUTDOWN,所以getTask方法返回了null,因而runWorker方法退出循环,该工作线程就退出了。


小结


我们这里通过一个简单的使用线程池异步执行任务的案例介绍了使用完线程池后如果不调用shutdown方法,则会导致线程池的线程资源一直不会被释放,并通过源码分析了没有被释放的原因。

所以在日常开发中使用线程池后一定不要忘记调用shutdown方法关闭。

相关文章
|
23天前
|
Java API 开发工具
【Azure Developer】Java代码实现获取Azure 资源的指标数据却报错 "invalid time interval input"
在使用 Java 调用虚拟机 API 获取指标数据时,因本地时区设置非 UTC,导致时间格式解析错误。解决方法是在代码中手动指定时区为 UTC,使用 `ZoneOffset.ofHours(0)` 并结合 `withOffsetSameInstant` 方法进行时区转换,从而避免因时区差异引发的时间格式问题。
117 3
|
4月前
|
资源调度 安全 Java
Java 大数据在智能教育在线实验室设备管理与实验资源优化配置中的应用实践
本文探讨Java大数据技术在智能教育在线实验室设备管理与资源优化中的应用。通过统一接入异构设备、构建四层实时处理管道及安全防护双体系,显著提升设备利用率与实验效率。某“双一流”高校实践显示,设备利用率从41%升至89%,等待时间缩短78%。该方案降低管理成本,为教育数字化转型提供技术支持。
99 1
|
5月前
|
机器学习/深度学习 消息中间件 存储
【高薪程序员必看】万字长文拆解Java并发编程!(9-2):并发工具-线程池
🌟 ​大家好,我是摘星!​ 🌟今天为大家带来的是并发编程中的强力并发工具-线程池,废话不多说让我们直接开始。
191 0
|
4月前
|
消息中间件 机器学习/深度学习 Java
java 最新技术驱动的智能教育在线实验室设备管理与实验资源优化实操指南
这是一份基于最新技术的智能教育在线实验室设备管理与实验资源优化的实操指南,涵盖系统搭建、核心功能实现及优化策略。采用Flink实时处理、Kafka消息队列、Elasticsearch搜索分析和Redis缓存等技术栈,结合强化学习动态优化资源调度。指南详细描述了开发环境准备、基础组件部署、数据采集与处理、模型训练、API服务集成及性能调优步骤,支持高并发设备接入与低延迟处理,满足教育机构数字化转型需求。代码已提供下载链接,助力快速构建智能化实验室管理系统。
133 44
|
3月前
|
前端开发 Java API
新手 Java 学习资料结合最新技术的精选推荐及高效学习资源参考
本文为新手推荐了涵盖Java基础到最新技术的学习资料,包括官方文档、在线课程、书籍、学习网站及实践平台,帮助系统掌握Java编程,并通过Spring Boot实战提升开发能力。
138 1
|
3月前
|
机器学习/深度学习 Java 大数据
Java 大视界 -- Java 大数据在智能政务公共资源交易数据分析与监管中的应用(202)
本篇文章深入探讨了 Java 大数据在智能政务公共资源交易监管中的创新应用。通过构建高效的数据采集、智能分析与可视化决策系统,Java 大数据技术成功破解了传统监管中的数据孤岛、效率低下和监管滞后等难题,为公共资源交易打造了“智慧卫士”,助力政务监管迈向智能化、精准化新时代。
|
8月前
|
存储 监控 Java
【Java并发】【线程池】带你从0-1入门线程池
欢迎来到我的技术博客!我是一名热爱编程的开发者,梦想是编写高端CRUD应用。2025年我正在沉淀中,博客更新速度加快,期待与你一起成长。 线程池是一种复用线程资源的机制,通过预先创建一定数量的线程并管理其生命周期,避免频繁创建/销毁线程带来的性能开销。它解决了线程创建成本高、资源耗尽风险、响应速度慢和任务执行缺乏管理等问题。
356 60
【Java并发】【线程池】带你从0-1入门线程池
|
7月前
|
Java 调度
【源码】【Java并发】【线程池】邀请您从0-1阅读ThreadPoolExecutor源码
当我们创建一个`ThreadPoolExecutor`的时候,你是否会好奇🤔,它到底发生了什么?比如:我传的拒绝策略、线程工厂是啥时候被使用的? 核心线程数是个啥?最大线程数和它又有什么关系?线程池,它是怎么调度,我们传入的线程?...不要着急,小手手点上关注、点赞、收藏。主播马上从源码的角度带你们探索神秘线程池的世界...
287 0
【源码】【Java并发】【线程池】邀请您从0-1阅读ThreadPoolExecutor源码
|
存储 安全 Java
深入理解Java并发编程:线程安全与锁机制
【5月更文挑战第31天】在Java并发编程中,线程安全和锁机制是两个核心概念。本文将深入探讨这两个概念,包括它们的定义、实现方式以及在实际开发中的应用。通过对线程安全和锁机制的深入理解,可以帮助我们更好地解决并发编程中的问题,提高程序的性能和稳定性。
|
存储 安全 Java
解锁Java并发编程奥秘:深入剖析Synchronized关键字的同步机制与实现原理,让多线程安全如磐石般稳固!
【8月更文挑战第4天】Java并发编程中,Synchronized关键字是确保多线程环境下数据一致性与线程安全的基础机制。它可通过修饰实例方法、静态方法或代码块来控制对共享资源的独占访问。Synchronized基于Java对象头中的监视器锁实现,通过MonitorEnter/MonitorExit指令管理锁的获取与释放。示例展示了如何使用Synchronized修饰方法以实现线程间的同步,避免数据竞争。掌握其原理对编写高效安全的多线程程序极为关键。
217 1