java中线程池的关闭问题

 更新时间:2023年08月10日 16:41:41   作者:赶路人儿  
这篇文章主要介绍了java中线程池的关闭问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教

java线程池的关闭问题

线程池是一个重要的资源,关闭线程池有两种方式:手动和自动。接下来我们一一讲解。

手动关闭

线程池有两个方法 shutdown()/shutdownNow()用来关闭,二者的区别:

  • shutdown() 执行后停止接受新任务,会把队列的任务执行完毕。
  • shutdownNow() 也是停止接受新任务,但会中断所有的任务,将线程池状态变为 stop。

两个方法都会中断线程,用户可自行判断是否需要响应中断。

通常,我们可以设置一个shutdownHook来关闭线程池:

Runtime.getRuntime().addShutdownHook(new Thread(() -> {
    try {
        executorService.shutdown();
        while(!executorService.awaitTermination(10,TimeUnit.SECONDS)) {}
    } catch(Exception e) {
    }
}));

自动关闭

首先要了解线程池在什么情况下会自动关闭。ThreadPoolExecutor 类(最常用的线程池实现类)的源码注释中有这么一句话:

A pool that is no longer referenced in a program and has no remaining threads will be shutdown automatically.

没有引用指向且没有剩余线程的线程池将会自动关闭。

那么什么情况下线程池中会没有剩余线程呢?

先来看一下 ThreadPoolExecutor 参数最全的构造方法:

/**
 * @param corePoolSize the number of threads to keep in the pool, even
 *           if they are idle, unless {@code allowCoreThreadTimeOut} is set
 *        核心线程数:即使是空闲状态也可以在线程池存活的线程数量,除非           
 *        allowCoreThreadTimeOut 设置为 true。
 * @param keepAliveTime when the number of threads is greater than
 *        the core, this is the maximum time that excess idle threads
 *        will wait for new tasks before terminating.
 *         存活时间:对于超出核心线程数的线程,空闲时间一旦达到存活时间,就会被销毁。
 */
public ThreadPoolExecutor(int corePoolSize,
                          int maximumPoolSize,
                          long keepAliveTime,
                          TimeUnit unit,
                          BlockingQueue<Runnable> workQueue,
                          ThreadFactory threadFactory,
                           RejectedExecutionHandler handler) { ... ... }

这里只关心与线程存活状态最紧密相关的两个参数:corePoolSize和keepAliveTime。

keepAliveTime参数指定了非核心线程的存活时间,非核心线程的空闲时间一旦达到这个值,就会被销毁,而核心线程则会继续存活,只要有线程存活,线程池也就不会自动关闭。

聪明的你一定会想到,如果把corePoolSize设置为0,再给keepAliveTime指定一个值的话,那么线程池在空闲一段时间之后,不就可以自动关闭了吗?

没错,这就是线程池自动关闭的第一种情况。

1、自动关闭线程池

核心线程数为 0 并指定线程存活时间

ThreadPoolExecutor executor = new ThreadPoolExecutor(0, 5,
                30L, TimeUnit.SECONDS, new LinkedBlockingQueue<>(15));
for (int i = 0; i < 20; i++) {
    executor.execute(() -> {
        // 简单地打印当前线程名称
        System.out.println(Thread.currentThread().getName());
    });
}

执行上述代码,当线程打印结束后等待30s,程序退出(代表了线程池自动关闭了)。

其实Executors.newCachedThrteadPool()创建的线程池,coreP00lSize=0且keepAliveTime=60s,所以也可以自动关闭。

其源码如下:

public class Executors {
    ... ...
    public static ExecutorService newCachedThreadPool() {
            return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
                                          60L, TimeUnit.SECONDS,
                                          new SynchronousQueue<Runnable>());
    }
    ... ...
}

如果将上面示例的代码corePoolSize改成大于0的数,当线程打印结束后程序一直不会退出。

2、自动关闭线程池

通过 allowCoreThreadTimeOut 控制核心线程存活时间

将核心线程数设置为0虽然可以实现线程池的自动关闭,但也存在一些弊端,根据线程池工作原理,当corePoolSize=0时新到来的任务会永远优先被放入任务队列,然后等待被处理,这显然会影响程序的执行效率。

那你可能要问了,有没有方法来关闭核心线程呢?

答案是肯定的,从 JDK 1.6 开始,ThreadPoolExecutor 类新增了一个allowCoreThreadTimeOut字段,这个字段值默认为false,可使用allowCoreThreadTimeOut()方法对其进行设置,如果设置为 true,那么核心线程数也将受keepAliveTime控制,此方法源码如下:

public void allowCoreThreadTimeOut(boolean value) {
    // 核心线程存活时间必须大于0,一旦开启,keepAliveTime 也必须大于0
    if (value && keepAliveTime <= 0)
        throw new IllegalArgumentException("Core threads must have nonzero keep alive times");
    // 将 allowCoreThreadTimeOut 值设为传入的参数值
    if (value != allowCoreThreadTimeOut) {
        allowCoreThreadTimeOut = value;
        // 开启后,清理所有的超时空闲线程,包括核心线程
        if (value)
            interruptIdleWorkers();
    }
}

接下来,把上面例子修改一下,运行:

ThreadPoolExecutor executor = new ThreadPoolExecutor(1, 5,
                30L, TimeUnit.SECONDS, new LinkedBlockingQueue<>(15));
executor.allowCoreThreadTimeOut(true);
for (int i = 0; i < 20; i++) {
            executor.execute(() -> {
               // 简单地打印当前线程名称
                System.out.println(Thread.currentThread().getName());
            });
}

 虽然corePoolSize>0,通过设置allowCoreThreadTimeOut=true,当线程打印结束后等待30s,程序正常退出(说明线程池自动关闭了)

3、自动关闭线程池

线程池中的线程设置为守护线程

ThreadPoolExecutor executor2 = new ThreadPoolExecutor(1, 5, 30, TimeUnit.SECONDS,
            new ArrayBlockingQueue<Runnable>(150),
            new ThreadFactory() { 
                public Thread newThread(Runnable r) {
                    Thread thread = new Thread(r, r.hashCode()+"");
                    thread.setDaemon(true);//设置成守护线程
                    return thread;
                }
            }
);
for (int i = 0; i < 20; i++) {
            executor2.execute(() -> {
               // 简单地打印当前线程名称
                System.out.println(Thread.currentThread().getName());
            });
}

虽然corePoolSize>0,而且没有设置allowCoreThreadTimeOut,但是在创建线程池时通过ThreadFactory指定了线程为守护线程。

当线程打印结束后,无需等待程序正常退出(说明线程池自动关闭了)。

当然,这里是在main函数中执行,不存在其他非守护线程哈。

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • Java 面试题基础知识集锦

    Java 面试题基础知识集锦

    本文主要介绍Java基础面试题集锦,这里整理了面试java工程师的基础知识题锦,有需要的小伙伴可以参考下
    2016-09-09
  • SpringBoot中如何使用Assert进行断言校验

    SpringBoot中如何使用Assert进行断言校验

    Java 提供了内置的 assert 机制,而 Spring 框架也提供了更强大的 Assert 工具类来帮助开发者进行参数校验和状态检查,下面我们就来看看SpringBoot中如何使用Assert进行断言校验吧
    2025-07-07
  • Atomikos + MybatisPlus解决多数据源事务一致性问题解决

    Atomikos + MybatisPlus解决多数据源事务一致性问题解决

    在实际项目的开发过程中,我们经常会遇到在同一个项目或微服务中牵涉到使用两个或多个数据源的,本文主要介绍了Atomikos + MybatisPlus解决多数据源事务一致性问题解决,具有一定的参考价值,感兴趣的可以了解一下
    2024-07-07
  • Java实现FTP批量大文件上传下载篇1

    Java实现FTP批量大文件上传下载篇1

    这篇文章主要为大家详细介绍了Java实现FTP批量大文件上传下载的基础篇,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2016-08-08
  • Java实现十进制与二进制互转的示例详解

    Java实现十进制与二进制互转的示例详解

    这篇文章主要为大家详细介绍了Java如何实现十进制与二进制的互转,文中的示例代码讲解详细,对我们学习Java有一定帮助,需要的可以参考一下
    2022-11-11
  • Spring Cloud Ribbon 负载均衡使用策略示例详解

    Spring Cloud Ribbon 负载均衡使用策略示例详解

    Spring Cloud Ribbon 是基于Netflix Ribbon 实现的一套客户端负载均衡工具,Ribbon客户端组件提供了一系列的完善的配置,如超时,重试等,这篇文章主要介绍了Spring Cloud Ribbon 负载均衡使用策略示例详解,需要的朋友可以参考下
    2023-03-03
  • 如何使用Jackson和JSON Pointer查询解析任何JSON节点

    如何使用Jackson和JSON Pointer查询解析任何JSON节点

    本文介绍了JSON Pointer是字符串表达式,可以非常方便解析复杂JSON节点值,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-09-09
  • java图片和文本同时提交到表单的实例代码

    java图片和文本同时提交到表单的实例代码

    在本篇文章里小编给大家整理的是关于java实现图片和文本同时提交到表单的相关内容,有需要的朋友们可以学习下。
    2020-02-02
  • mybatis-plus 处理大数据插入太慢的解决

    mybatis-plus 处理大数据插入太慢的解决

    这篇文章主要介绍了mybatis-plus 处理大数据插入太慢的解决,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-12-12
  • Spring Boot分离配置文件的多种方式总结

    Spring Boot分离配置文件的多种方式总结

    Spring Boot可以外部化程序配置,以便可以在不同环境中使用相同的应用程序代码;当然Spring Boot可以将配置文件进行拆分,以便于激活不同的运行环境,下面这篇文章主要给大家总结介绍了关于Spring Boot分离配置文件的多种方式,需要的朋友可以参考下
    2022-11-11

最新评论