java线程池使用后到底要关闭吗

作者:烦嚣的人 时间:2022-03-17 04:28:43 

线程池做什么

网络请求通常有两种形式:

第一种,请求不是很频繁,而且每次连接后会保持相当一段时间来读数据或者写数据,最后断开,如文件下载,网络流媒体等。

另一种形式是请求频繁,但是连接上以后读/写很少量的数据就断开连接。考虑到服务的并发问题,如果每个请求来到以后服务都为它启动一个线程,那么这对服务的资源可能会造成很大的浪费,特别是第二种情况。

因为通常情况下,创建线程是需要一定的耗时的,设这个时间为T1,而连接后读/写服务的时间为T2,当T1>>T2时,我们就应当考虑一种策略或者机制来控制,使得服务对于第二种请求方式也能在较低的功耗下完成。

通常,我们可以用线程池来解决这个问题,首先,在服务启动的时候,我们可以启动好几个线程,并用一个容器(如线程池)来管理这些线程。

当请求到来时,可以从池中取一个线程出来,执行任务(通常是对请求的响应),当任务结束后,再将这个线程放入池中备用;

如果请求到来而池中没有空闲的线程,该请求需要排队等候。最后,当服务关闭时销毁该池即可。

然而最近在开发中用到了java的线程池,然后就很疑惑这个线程池到底要不要手动关闭,感觉是要关闭的,但是没人强调线程池用完要关闭。so今天来试验下到底线程池用完要不要关闭。

直接上实验代码


public static void main(String[] args) throws Exception {
 //用于获取到本java进程,进而获取总线程数
RuntimeMXBean runtimeBean = ManagementFactory.getRuntimeMXBean();
String jvmName = runtimeBean.getName();
System.out.println("JVM Name = " + jvmName);
long pid = Long.valueOf(jvmName.split("@")[0]);
System.out.println("JVM PID = " + pid);
ThreadMXBean bean = ManagementFactory.getThreadMXBean();
int n = 30000;
for (int i = 0; i < n; i++) {
 ThreadPoolExecutor executor = new ThreadPoolExecutor(10,20,1000,TimeUnit.SECONDS,new LinkedBlockingDeque<>());
 for(int j=0;j<10;j++){
  executor.execute(()->{
   System.out.println("当前线程总数为:"+bean.getThreadCount());
  });
 }
}
Thread.sleep(10000);
System.out.println("线程总数为 = " + bean.getThreadCount());
}

简单来说就是在一个 for 循环中创建线程池,然后执行一个打印任务(不执行任务线程不会真正创建),打印出当前 java 进程的总线程数,下面是打印部分结果:

java线程池使用后到底要关闭吗

线程

可以看到在创建到 15 万个线程是爆内存,内存占用百分百后 java 应用崩溃。说明线程未被回收。

PS:内存占用百分百后,部分应用开始出现异常,界面花屏,闪屏,不能正常绘制gui,不知道为啥,即使后面内存占用降下来也一样,只能重启应用。

结论

使用完线程池一定记得回收,否则跑着跑着就内存 * 崩溃。回收函数如下:


//执行此函数后线程池不再接收新任务,并等待所有任务执行完毕后销毁线程。此函数不会等待销毁完毕
executor.shutdown();
//立即结束所有线程,不管是否正在运行,返回未执行完毕的任务列表
executor.shutdownNow();

来源:https://www.cnblogs.com/wuyoucao/p/10247012.html

标签:java,线程池,关闭
0
投稿

猜你喜欢

  • Android GestureDetector实现手势滑动效果

    2023-10-01 04:37:50
  • 详解Java单元测试之Junit框架使用教程

    2022-03-06 02:55:56
  • go打包aar及flutter调用aar流程详解

    2023-06-24 17:39:21
  • Java实现FTP上传与下载功能

    2021-09-22 18:28:51
  • C# DateTime与时间戳转换实例

    2022-12-12 08:34:12
  • Dagger2 Android依赖注入学习笔记

    2021-11-27 17:15:54
  • 一文掌握MyBatis Plus的条件构造器方法

    2023-06-18 13:00:26
  • 基于request获取访问者真实IP代码示例

    2023-02-15 02:45:13
  • 详解Java中的时区类TimeZone的用法

    2023-11-29 02:03:09
  • 多线程如何解决for循环效率的问题

    2023-12-02 08:31:55
  • Java编程实现基于用户的协同过滤推荐算法代码示例

    2022-09-06 12:44:24
  • 生成8位随机不重复的数字编号的方法

    2023-11-26 07:00:29
  • springboot中使用rabbitt的详细方法

    2023-06-17 09:57:43
  • 使用JDBC4.0操作XML类型的字段(保存获取xml数据)的方法

    2021-08-25 17:44:38
  • mybatis-plus多表联查join的实现

    2023-11-24 06:49:56
  • SpringBoot多环境开发与日志小结

    2021-09-18 19:05:44
  • java8 stream的多字段排序实现(踩坑)

    2023-10-22 11:06:31
  • 详解C#使用AD(Active Directory)验证内网用户名密码

    2023-03-03 23:17:47
  • Java用单向环形链表来解决约瑟夫环Josepfu问题

    2023-03-13 18:54:20
  • 基于Tomcat7、Java、WebSocket的服务器推送聊天室实例

    2023-11-25 23:35:34
  • asp之家 软件编程 m.aspxhome.com