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 # ThreadPoolExecutor # ThreadPoolExecutor如何使用 # ThreadPoolExecutor简单介绍 # java 定时器线程池（ScheduledThreadPoolExecutor）的实现 # Java线程池ThreadPoolExecutor原理及使用实例 # java中ThreadPoolExecutor常识汇总 # Java ThreadPoolExecutor 线程池的使用介绍 # Java自带定时任务ScheduledThreadPoolExecutor实现定时器和延时加载功能 # java ThreadPoolExecutor 并发调用实例详解 # Java ThreadPoolExecutor的参数深入理解 # java中Executor # ExecutorService # ThreadPoolExecutor详解 # 详解Java并发包中线程池ThreadPoolExecutor # 池中 # 发短信 # 达到了 # 满了 # 会把 # 自己的 # 复用 # 的是 # 太多 # 没有任何 # 希望能 # 有几个 # 可以直接 # 还未 # 这个时候 # 可以使用 # 能把 # 比较大 # 谢谢大家 # 久了

返回目录在线咨询

上一篇： ae制作网页,ae源码从哪里下载？
下一篇：php数组存入数值型数据_php数组数字元素添加存储技巧【解析】

您的项目需求

*请认真填写需求信息，我们会在24小时内与您取得联系。

全网整合营销服务商

java&nbsp;&nbsp;ThreadPoolExecutor使用方法简单介绍

您的项目需求

java ThreadPoolExecutor使用方法简单介绍