高并发之——不得不说的线程池与ThreadPoolExecutor类浅析

1、抛砖引玉

既然Java中支持以多线程的方式来执行相应的任务，但为何在JDK1.5中又提供了线程池技术呢？这个问题你们自行脑补，多动脑，确定没坏处，哈哈哈。。。

提及Java中的线程池技术，在不少框架和异步处理中间件中都有涉及，并且性能经受起了长久的考验。能够这样说，Java的线程池技术是Java最核心的技术之一，在Java的高并发领域中，Java的线程池技术是一个永远绕不开的话题。既然Java的线程池技术这么重要（怎么能说是这么重要呢？那是至关的重要，那家伙老重要了，哈哈哈），那么，本文咱们就来简单的说下线程池与ThreadPoolExecutor类。至于线程池中的各个技术细节和ThreadPoolExecutor的底层原理和源码解析，咱们会在【高并发专题】专栏中进行深度解析。

引言：本文是高并发中线程池的开篇之做，就暂时先不深刻讲解，只是让你们从总体上认识下线程池中最核心的类之一——ThreadPoolExecutor，关于ThreadPoolExecutor的底层原理和源码实现，以及线程池中的其余技术细节的底层原理和源码实现，咱们会在【高并发专题】接下来的文章中，进行死磕。

2、Thread直接建立线程的弊端

（1）每次new Thread新建对象，性能差。
（2）线程缺少统一管理，可能无限制的新建线程，相互竞争，有可能占用过多系统资源致使死机或OOM。
（3）缺乏更多的功能，如更多执行、按期执行、线程中断。
（4）其余弊端，你们自行脑补，多动脑，没坏处，哈哈。

3、线程池的好处

（1）重用存在的线程，减小对象建立、消亡的开销，性能佳。
（2）能够有效控制最大并发线程数，提升系统资源利用率，同时能够避免过多资源竞争，避免阻塞。
（3）提供定时执行、按期执行、单线程、并发数控制等功能。
（4）提供支持线程池监控的方法，可对线程池的资源进行实时监控。
（5）其余好处，你们自行脑补，多动脑，没坏处，哈哈。

4、线程池

1.线程池类结构关系

线程池中的一些接口和类的结构关系以下图所示。

后文会死磕这些接口和类的底层原理和源码。

2.建立线程池经常使用的类——Executors

• Executors.newCachedThreadPool：建立一个可缓存的线程池，若是线程池的大小超过了须要，能够灵活回收空闲线程，若是没有可回收线程，则新建线程
• Executors.newFixedThreadPool：建立一个定长的线程池，能够控制线程的最大并发数，超出的线程会在队列中等待
• Executors.newScheduledThreadPool：建立一个定长的线程池，支持定时、周期性的任务执行
• Executors.newSingleThreadExecutor: 建立一个单线程化的线程池，使用一个惟一的工做线程执行任务，保证全部任务按照指定顺序（先入先出或者优先级）执行
• Executors.newSingleThreadScheduledExecutor:建立一个单线程化的线程池，支持定时、周期性的任务执行

• Executors.newWorkStealingPool：建立一个具备并行级别的work-stealing线程池

  3.线程池实例的几种状态

• Running:运行状态，能接收新提交的任务，而且也能处理阻塞队列中的任务
• Shutdown: 关闭状态，不能再接收新提交的任务，可是能够处理阻塞队列中已经保存的任务，当线程池处于Running状态时，调用shutdown()方法会使线程池进入该状态
• Stop: 不能接收新任务，也不能处理阻塞队列中已经保存的任务，会中断正在处理任务的线程，若是线程池处于Running或Shutdown状态，调用shutdownNow()方法，会使线程池进入该状态
• Tidying: 若是全部的任务都已经终止，有效线程数为0（阻塞队列为空，线程池中的工做线程数量为0），线程池就会进入该状态。

• Terminated: 处于Tidying状态的线程池调用terminated()方法，会使用线程池进入该状态

注意：不须要对线程池的状态作特殊的处理，线程池的状态是线程池内部根据方法自行定义和处理的。

4.合理配置线程的一些建议

（1）CPU密集型任务，就须要尽可能压榨CPU，参考值能够设置为NCPU+1(CPU的数量加1)。
（2）IO密集型任务，参考值能够设置为2*NCPU（CPU数量乘以2）

5、线程池最核心的类之一——ThreadPoolExecutor

1.构造方法

ThreadPoolExecutor参数最多的构造方法以下：

public ThreadPoolExecutor(int corePoolSize,
                              int maximumPoolSize,
                              long keepAliveTime,
                              TimeUnit unit,
                              BlockingQueue<Runnable> workQueue,
                              ThreadFactory threadFactory,
                              RejectedExecutionHandler rejectHandler)

其余的构造方法都是调用的这个构造方法来实例化对象，能够说，咱们直接分析这个方法以后，其余的构造方法咱们也明白是怎么回事了！接下来，就对此构造方法进行详细的分析。

注意：为了更加深刻的分析ThreadPoolExecutor类的构造方法，会适当调整参数的顺序进行解析，以便于你们更能深刻的理解ThreadPoolExecutor构造方法中每一个参数的做用。

上述构造方法接收以下参数进行初始化：

（1）corePoolSize：核心线程数量。

（2）maximumPoolSize：最大线程数。

（3）workQueue：阻塞队列，存储等待执行的任务，很重要，会对线程池运行过程产生重大影响。

其中，上述三个参数的关系以下所示：

• 若是运行的线程数小于corePoolSize，直接建立新线程处理任务，即便线程池中的其余线程是空闲的。
• 若是运行的线程数大于等于corePoolSize，而且小于maximumPoolSize，此时，只有当workQueue满时，才会建立新的线程处理任务。
• 若是设置的corePoolSize与maximumPoolSize相同，那么建立的线程池大小是固定的，此时，若是有新任务提交，而且workQueue没有满时，就把请求放入到workQueue中，等待空闲的线程，从workQueue中取出任务进行处理。
• 若是运行的线程数量大于maximumPoolSize，同时，workQueue已经满了，会经过拒绝策略参数rejectHandler来指定处理策略。

根据上述三个参数的配置，线程池会对任务进行以下处理方式：

当提交一个新的任务到线程池时，线程池会根据当前线程池中正在运行的线程数量来决定该任务的处理方式。处理方式总共有三种：直接切换、使用无限队列、使用有界队列。

• 直接切换经常使用的队列就是SynchronousQueue。
• 使用无限队列就是使用基于链表的队列，好比：LinkedBlockingQueue，若是使用这种方式，线程池中建立的最大线程数就是corePoolSize，此时maximumPoolSize不会起做用。当线程池中全部的核心线程都是运行状态时，提交新任务，就会放入等待队列中。
• 使用有界队列使用的是ArrayBlockingQueue，使用这种方式能够将线程池的最大线程数量限制为maximumPoolSize，能够下降资源的消耗。可是，这种方式使得线程池对线程的调度更困难，由于线程池和队列的容量都是有限的了。

根据上面三个参数，咱们能够简单得出如何下降系统资源消耗的一些措施：

• 若是想下降系统资源的消耗，包括CPU使用率，操做系统资源的消耗，上下文环境切换的开销等，能够设置一个较大的队列容量和较小的线程池容量。这样，会下降线程处理任务的吞吐量。
• 若是提交的任务常常发生阻塞，能够考虑调用设置最大线程数的方法，从新设置线程池最大线程数。若是队列的容量设置的较小，一般须要将线程池的容量设置的大一些，这样，CPU的使用率会高些。若是线程池的容量设置的过大，并发量就会增长，则须要考虑线程调度的问题，反而可能会下降处理任务的吞吐量。

接下来，咱们继续看ThreadPoolExecutor的构造方法的参数。

（4）keepAliveTime：线程没有任务执行时最多保持多久时间终止
当线程池中的线程数量大于corePoolSize时，若是此时没有新的任务提交，核心线程外的线程不会当即销毁，须要等待，直到等待的时间超过了keepAliveTime就会终止。

（5）unit：keepAliveTime的时间单位

（6）threadFactory：线程工厂，用来建立线程
默认会提供一个默认的工厂来建立线程，当使用默认的工厂来建立线程时，会使新建立的线程具备相同的优先级，而且是非守护的线程，同时也设置了线程的名称

（7）rejectHandler：拒绝处理任务时的策略

若是workQueue阻塞队列满了，而且没有空闲的线程池，此时，继续提交任务，须要采起一种策略来处理这个任务。
线程池总共提供了四种策略：

• 直接抛出异常，这也是默认的策略。实现类为AbortPolicy。
• 用调用者所在的线程来执行任务。实现类为CallerRunsPolicy。
• 丢弃队列中最靠前的任务并执行当前任务。实现类为DiscardOldestPolicy。
• 直接丢弃当前任务。实现类为DiscardPolicy。

2.ThreadPoolExecutor提供的启动和中止任务的方法

（1）execute():提交任务，交给线程池执行
（2）submit():提交任务，可以返回执行结果 execute+Future
（3）shutdown():关闭线程池，等待任务都执行完
（4）shutdownNow():当即关闭线程池，不等待任务执行完

3.ThreadPoolExecutor提供的适用于监控的方法

（1）getTaskCount()：线程池已执行和未执行的任务总数 （2）getCompletedTaskCount()：已完成的任务数量 （3）getPoolSize()：线程池当前的线程数量 （4）getCorePoolSize()：线程池核心线程数 （5）getActiveCount():当前线程池中正在执行任务的线程数量