java ThreadPoolExecutor使用方法简单介绍
java ThreadPoolExecutor
前言：
在项目中如果使用发短信这个功能，一般会把发短信这个动作变成异步的，因为大部分情况下，短信到底是发送成功或者失败，都不能影响主流程。当然像发送MQ消息等操作也是可以封装成异步操作的。
使用基本的New Thread
如果想一个操作变成异步的，可以直接new thread，然后在run方法中实现业务操作即可。例如：
new Thread(new Runnable() {
public void run() {
//发短信、发MQ消息等
}
});
但是这种方式有几个缺点。
1.每次都会new一个线程，执行完后销毁，不能复用；
2.如果系统的并发量刚好比较大，需要大量线程，那么这种每次new的方式会抢资源的。
ThreadPoolExecutor
我们可以使用jdk1.5中的ThreadPoolExecutor来封装异步操作。ThreadPoolExecutor的好处是可以做到线程复用，并且使用尽量少的线程去执行更多的任务，效率和性能都相当不错。demo代码如下：
public class ThreadPool {
private static ThreadPoolExecutor threadPool = new ThreadPoolExecutor(8, 12, 30,
TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(50000), new ThreadPoolExecutor.AbortPolicy());
public static ThreadPoolExecutor getThreadPool() {
return threadPool;
}
}
参数介绍
public ThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
RejectedExecutionHandler handler) {
}
corePoolSize：当workQueue队列中的元素还未到达最大值时，corePoolSize表示的池中线程数量的最大值；
maximumPoolSize：线程池中允许的最大线程数；
keepAliveTime：当前池中的线程数如果超过了corePoolSize，那么超出那些线程如果空闲太久了，应该需要销毁的。keepAliveTime就是的是这些线程的最大空闲时间；
unit：keepAliveTime的时间单位；
workQueue：当池中线程数的数量已经达到了corePoolSize，那么如果请求还继续过来，会把请求对应的task放入队列中；
handler：当workQueue满了，池中的线程数又达到了maximumPoolSize，这个时候已经没有多余的资源处理请求了，需要RejectedExecutionHandler 来处理。拒绝处理或者丢弃任务等等。
执行过程
当没有请求时，线程池中没有任何线程；
当有请求时，创建线程，一直到池中的线程数等于corePoolSize；
如果请求太多，需要更多的线程来处理的话，ThreadPoolExecutor选择把请求放入队列中，暂时不新建线程；
如果workQueue也满了，ThreadPoolExecutor会继续创建线程，直到线程数量跟maximumPoolSize相等；
线程数达到maximumPoolSize了，同时workQueue也慢了，就只能把请求丢给RejectedExecutionHandler 来处理。
备注
使用ThreadPoolExecutor时，需要根据自己的业务情况，适当的指定参数值的大小。
感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！
- java 定时器线程池（ScheduledThreadPoolExecutor）的实现
- Java线程池ThreadPoolExecutor原理及使用实例
- java中ThreadPoolExecutor常识汇总
- Java ThreadPoolExecutor 线程池的使用介绍
- Java自带定时任务ScheduledThreadPoolExecutor实现定时器和延时加载功能
- java ThreadPoolExecutor 并发调用实例详解
- Java ThreadPoolExecutor的参数深入理解
- java中Executor，ExecutorService，ThreadPoolExecutor详解
- 详解Java并发包中线程池ThreadPoolExecutor
相关文章
Spring中的BeanFactory与FactoryBean区别详解
这篇文章主要介绍了Spring中的BeanFactory与FactoryBean区别详解,BeanFactory是一个接口,它是spring中的一个工厂,FactoryBean也是一个接口,实现了3个方法,通过重写其中方法自定义生成bean,需要的朋友可以参考下2024-01-01
Java语言是支持多线程的，为了解决线程并发的问题，在语言内部引入了 同步块 和 volatile 关键字机制2013-09-09
二分查找树是一种有组织的二叉树。我们可以通过链接节点表示这样一棵树，二分查找树（Binary Search Tree）的基本操作有搜索、求最大值、求最小值、求前驱、求后继、插入及删除，对java二分查找树相关知识感兴趣的朋友一起看看吧2021-07-07
这篇文章主要介绍了Java8 CompletableFuture详解,CompletableFuture extends Future提供了方法，一元操作符和促进异步性以及事件驱动编程模型,需要的朋友可以参考下2014-06-06
java的各种集合为什么不安全(List、Set、Map)以及代替方案
这篇文章主要介绍了java的各种集合为什么不安全(List、Set、Map)以及代替方案，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2020-10-10
这篇文章主要介绍了java参数传递之值传递和引用传递,引用了两个代码实例来讲解，有感兴趣的同学可以研究下2021-02-02
这篇文章主要介绍了Java无界阻塞队列DelayQueue详细解析,DelayQueue是一个支持时延获取元素的无界阻塞队列,队列使用PriorityQueue来实现,队列中的元素必须实现Delayed接口,在创建元素时可以指定多久才能从队列中获取当前元素,需要的朋友可以参考下2023-12-12
MyBatis是一个优秀的持久层框架，它对jdbc的操作数据库的过程进行封装，使开发者只需要关注SQL本身，而不需要花费精力去处理例如注册驱动、创建connection、创建statement、手动设置参数、结果集检索等jdbc繁杂的过程代码本文将为大家初步的介绍一下MyBatis的使用2022-07-07
Cookies是 web站点放置到你的硬盘上的程序。它们驻留在你的计算机上收集关于你在因特网上所做的一切事情的信息，并且 web站点可以在任何时候读取到Cookies收集到的所有信息2021-06-06
本文主要介绍Java 高并发JDK8的支持，这里整理了详细的资料及1. LongAdder 2. CompletableFuture 3. StampedLock的介绍，有兴趣的小伙伴可以参考下2016-09-09
最新评论