#### 为什么要使用线程池 * 反复创建线程开销大 * 过多的线程会占用太多内存 #### 线程池的好处 * 加快响应速度 * 合理利用 CPU 和内存 * 统一管理 #### 线程池适合应用的场合 服务器接受大量请求时，使用线程池技术是非常合适的，它可以大大减少线程的创建和销毁次数，提高服务器的工作效率，实际在开发中，如果需要创建 5 个以上的线程，那么就可以使用线程池来管理 #### 线程池构造函数的参数 |参数名|含义| |-------|-------| |corePoolSize|核心线程数| |maxPoolSize|最大线程数| |keepAliveTime|保持存活时间| |workQueue|任务存储队列| |threadFactory|线程工厂| |handle|拒绝策略| ##### keepAliveTime 如果线程池当前的线程数多于 corePoolSize，并且多于的线程空闲时间超过 keepAliveTime，它们就会被终止 ##### workQueue * 直接交换（SynchronousQueue）：不存储元素的阻塞队列，每个插入操作必须等到另一个线程调用移除操作，否则插入操作一直处于阻塞状态，吞吐量通常要高于 LinkedBlockingQuene * 无界队列（LinkedBlockingQueue）：基于链表结构的无界阻塞队列，按 FIFO 排序任务，吞吐量通常要高于 ArrayBlockingQuene * 有界队列（ArrayBlockingQueue）：基于数组结构的有界阻塞队列，按 FIFO 排序任务 ##### handle * AbortPolicy：直接抛出异常，默认策略 * CallerRunsPolicy：用调用者所在的线程来执行任务 * DiscardOldestPolicy：丢弃阻塞队列中靠最前的任务，并执行当前任务 * DiscardPolicy：直接丢弃任务 **添加线程的规则** * 如果线程小于 corePoolSize，即使其他工作线程处于空闲状态，也会创建一个新线程来运行新任务 * 如果线程等于（或大于）corePoolSize 但小于 maxPoolSize，则将任务放入队列 * 如果队列已满，并且线程数小于 maxPoolSize，则创建一个新线程来运行任务 * 如果队列已满，并且线程数大于或等于 maxPoolSize，则拒绝该任务 #### 增减线程的特点 - 通过设置 corePoolSize 和 maxPoolSize 相同，就可以创建固定大小的线程池 - 线程池希望保持较少的线程数，并且只有在负载变得很大时才增加它 - 通过设置 maxPoolSize 为很高的值，例如 Integer.MAX_VALUE，可以允许线程池容纳任意数量的并发任务 - 只有队列填满时才创建多于 corePoolSize 的线程，所以如果使用的是无界队列（例如 LinkedBlockingQueue）那么线程数就不会超过 corePoolSize #### 线程池的状态 * RUNNING：接受新任务并处理排队任务 * SHUTDOWN：不接受新任务，但处理排队任务 * STOP：不接受新任务，也不处理排队任务，并中断正在进行的任务 * TIDYING：所有任务都已终止，workerCount 为 0 时，线程会转换到 TIDYING 状态，并将运行 terminate() 钩子方法 * TERMINATED：terminate() 运行完成 #### JDK 提供的线程池 * newFixedThreadPool：创建一个定长线程池，可控制线程最大并发数，超出的线程会在队列中等待，由于传进去的LinkedBlockingQueue是没有容量上限的，所以当请求数越来越多，并且无法及时处理完毕的时候也就是请求堆积的时候，会容易造成占用大量的内存，可能会发生OОM * newSingleThreadExecutor：创建一个单线程化的Executor，即只创建唯一的工作者线程来执行任务，单工作线程最大的特点是可以保证顺序地执行各个任务，并且在任意给定的时间不会有多个线程是活动的，和newFixedThreadPool的原理基本一样，只不过把线程数直接设置成了1，所以这也会导致同样的问题，也就是当请求堆积的时候，可能会占用大量的内存 * newCachedThreadPool：创建一个可缓存线程池，如果线程池长度超过处理需要，可灵活回收空闲线程，若无可回收，则新建线程，这里的弊端在于第二个参数maximumPoolSize被设置为了Integer.MAX-VALUE，这可能会创建数量非常多的线程甚至导致OOM * newScheduledThreadPool：创建一个定长的线程池，而且支持定时的以及周期性的任务执行 * newWorkStealingPool ：创建一个具有抢占式操作的线程池 #### 线程池的关闭方式 - shutdown：平滑的关闭 ExecutorService，当调用这个方法时，ExecutorService会停止接受任何新的任务且等待已经提交的任务执行完成，当所有已经提交的任务执行完毕后将会关闭 ExecutorService - isShutdown：线程池是否关闭，当调用 shutdown() 方法后返回为true - isTerminated：判断线程池关闭后所有的任务是否都执行完了，所有提交的任务完成后返回为true - awaitTermination：两个参数，一个是 timeout 即超时时间，另一个是 unit 即时间单位，这个方法会使线程等待 timeout 时长，当超过 timeout 时间后，会监测 ExecutorService 是否已经关闭，若关闭则返回 true，否则返回false - shutdownNow：强制关闭 ExecutorService，它将取消所有运行中的任务和在工作队列中等待的任务，这个方法返回一个 List 列表，列表中返回的是等待在工作队列中的任务