java中线程池最实用的创建与关闭指南
更新时间：2021年09月09日 10:47:39 作者：jacky 郑
试中经常会问到,创建一个线程池需要哪些参数啊,线程池的工作原理啊,却很少会问到线程池如何安全关闭的,下面这篇文章主要给大家介绍了关于java中线程池最实用的创建与关闭的相关资料,需要的朋友可以参考下
前言
在日常的开发工作当中，线程池往往承载着一个应用中最重要的业务逻辑，因此我们有必要更多地去关注线程池的执行情况，包括异常的处理和分析等。
线程池创建
避免使用Executors创建线程池，主要是避免使用其中的默认实现，那么我们可以自己直接调用ThreadPoolExecutor的构造函数来自己创建线程池。在创建的同时，给BlockQueue指定容量就可以了。
private static ExecutorService executor = new ThreadPoolExecutor(10, 10,
60L, TimeUnit.SECONDS,
new ArrayBlockingQueue(10));
这种情况下，一旦提交的线程数超过当前可用线程数时，就会抛出java.util.concurrent.RejectedExecutionException，这是因为当前线程池使用的队列是有边界队列，队列已经满了便无法继续处理新的请求。但是异常（Exception）总比发生错误（Error）要好。
除了自己定义ThreadPoolExecutor外。还有其他方法。这个时候第一时间就应该想到开源类库，如apache和guava等。
推荐使用guava提供的ThreadFactoryBuilder来创建线程池。
public class ExecutorsDemo {
private static ThreadFactory namedThreadFactory = new ThreadFactoryBuilder()
.setNameFormat("demo-pool-%d").build();
private static ExecutorService pool = new ThreadPoolExecutor(5, 200,
0L, TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<Runnable>(1024), namedThreadFactory, new ThreadPoolExecutor.AbortPolicy());
public static void main(String[] args) {
for (int i = 0; i < Integer.MAX_VALUE; i++) {
pool.execute(new SubThread());
}
}
}
只需要执行shutdown就可以优雅关闭
package com.zxd.concurrent;
import com.google.common.collect.Lists;
import java.util.List;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
public class ThreadPool {
public static void main(String[] args) {
// TODO 如何正确优雅简单的关闭线程池 ，无须其他多余操 ；创建线程池我选择用这种方法比较可靠
ThreadPoolExecutor executor = new ThreadPoolExecutor(5, 10, 60L, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>());
//接收处理数据的结果集合
List<Integer> resList = Lists.newArrayList();
//开启的任务 我们设置的核心处理线程数5个所以 会有多出来的线程在队列中等待
for (int i = 0; i < 30; i++) {
executor.execute(new Task(i, resList));
}
//1、关闭线程池 一定要在循环结束关闭
//2、这个关闭方法不会立即关闭所有在执行的任务线程，
executor.shutdown();
//4.这里是检查线程池是否所有任务都执行完毕关闭
int j = 0;
while (true) {
//5.这里是等线程池彻底关闭以后做的判断 保证所有线程池已经全部关闭退出while循环
if (executor.isTerminated()) {
System.out.println("所有线程已经运行完毕:" + j);
break;
}
// 为避免一直循环 加个睡眠
try {
//如果执行shutdown方法没有关闭的线程池线程池会尝试关闭
System.out.println("尝试关闭线程次数:" + j);
j++;
Thread.sleep(300);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
//FIXME 3、下面的方法会立即关闭线程池，没有执行完的也不会在执行了，如果有等待队列的任务也不会继续执行
System.out.println("【完成的总线程数】：" + resList.size());
}
static class Task implements Runnable {
int name;
List<Integer> list;
public Task(int name, List<Integer> list) {
this.name = name;
this.list = list;
}
@Override
public void run() {
for (int i = 1; i <= 10; i++) {
int j = i * 10;
// 做业务处理
//System.out.println("task " + name + " is running");
}
list.add(name + 1);
System.out.println("task " + name + " is over");
}
}
}
输出结果
task 0 is over
task 3 is over
task 1 is over
task 2 is over
task 7 is over
task 6 is over
task 5 is over
尝试关闭线程次数:0
task 10 is over
task 9 is over
task 4 is over
task 8 is over
task 14 is over
task 13 is over
task 12 is over
task 11 is over
task 18 is over
task 17 is over
task 16 is over
task 15 is over
task 22 is over
task 21 is over
task 20 is over
task 19 is over
task 26 is over
task 25 is over
task 24 is over
task 23 is over
task 29 is over
task 28 is over
task 27 is over
所有线程已经运行完毕:1
【完成的总线程数】：30
执行shutdownNow关闭的测试
package com.zxd.concurrent;
import com.google.common.collect.Lists;
import java.util.List;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
public class ThreadPool {
public static void main(String[] args) {
// TODO 如何正确优雅简单的关闭线程池 ，无须其他多余操 ；创建线程池我选择用这种方法比较可靠
ThreadPoolExecutor executor = new ThreadPoolExecutor(5, 10, 60L, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>());
//接收处理数据的结果集合
List<Integer> resList = Lists.newArrayList();
//开启的任务 我们设置的核心处理线程数5个所以 会有多出来的线程在队列中等待
for (int i = 0; i < 200; i++) {
executor.execute(new Task(i, resList));
}
//1、关闭线程池 一定要在循环结束关闭
//2、这个关闭方法不会立即关闭所有在执行的任务线程，
// executor.shutdown();
//FIXME 3、下面的方法会立即关闭线程池，没有执行完的也不会在执行了，如果有等待队列的任务也不会继续执行
List<Runnable> list = executor.shutdownNow();
System.out.println("c剩余的没有执行的任务【线程数】= " + list.size());
System.out.println("【完成的总线程数】：" + resList.size());
//4.这里是检查线程池是否所有任务都执行完毕关闭
int j = 0;
while (true) {
//5.这里是等线程池彻底关闭以后做的判断 保证所有线程池已经全部关闭退出while循环
if (executor.isTerminated()) {
System.out.println("所有线程已经运行完毕:" + j);
break;
}
// 为避免一直循环 加个睡眠
try {
//如果执行shutdown方法没有关闭的线程池线程池会尝试关闭
System.out.println("尝试关闭线程次数:" + j);
j++;
Thread.sleep(300);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
static class Task implements Runnable {
int name;
List<Integer> list;
public Task(int name, List<Integer> list) {
this.name = name;
this.list = list;
}
@Override
public void run() {
for (int i = 1; i <= 10; i++) {
int j = i * 10;
// 做业务处理
//System.out.println("task " + name + " is running");
}
list.add(name + 1);
System.out.println("task " + name + " is over");
}
}
}
输出结果
总结
到此这篇关于java中线程池最实用的创建与关闭的文章就介绍到这了,更多相关java线程池创建与关闭内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
这篇文章主要介绍了常用数字签名算法RSA与DSA的Java程序内实现示例,一般来说DSA算法用于签名的效率会比RSA要快,需要的朋友可以参考下2016-04-04
这篇文章主要介绍了spring boot mogodb多条件拼接的解决方法,非常不错，具有一定的参考借鉴价值，需要的朋友可以参考下2018-08-08
本篇文章是对Java中数组内存分配进行了详细的分析介绍，需要的朋友参考下2013-05-05
本文主要介绍了springboot中websocket简单实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2023-01-01
这篇文章主要介绍了idea搭建ssh框架的超详细教程，本文通过图文实例代码相结合给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下2022-03-03
这篇文章主要介绍了Java内部类深入解析,在java中,我们被允许在编写一个类(外部类OuterClass)时,在其内部再嵌套一个类(嵌套类NestedClass),java将嵌套类分为两种,非静态内部类(简称内部类)和 静态内部,需要的朋友可以参考下2023-12-12
Java工厂模式是一种创建对象的设计模式，它可以在不暴露对象创建逻辑的情况下，将对象的创建委托给子类或者其他对象。本文就来深入剖析一下Java工厂模式是如何让你的代码更灵活、可扩展、易维护的2023-05-05
这篇文章主要为大家详细介绍了java实现图片分割指定大小，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2021-09-09
这篇文章主要介绍了如何基于java语言实现八皇后问题,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2019-12-12
Java事务的类型有三种：JDBC事务、JTA(Java Transaction API)事务、容器事务，本文详细介绍了JDBC事务与JTA分布式事务，有需要的可以了解一下。2016-11-11
最新评论