欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

java ThreadPoolExecutor使用方法简单介绍

程序员文章站 2024-03-07 13:39:27
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时,需要根据自己的业务情况,适当的指定参数值的大小。

感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!