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-01java的各种集合为什么不安全(List、Set、Map)以及代替方案
这篇文章主要介绍了java的各种集合为什么不安全(List、Set、Map)以及代替方案,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧2020-10-10
最新评论