Java线程池

一、 线程池的实现原理

1. 线程池处理流程
   

2. 线程池执行的四种情况：
   1）如果当前运行的线程少于 corePoolSize，则创建新线程来执行任务（注意，执行这一步骤需要获取全局锁）。
   2）如果运行的线程等于或多于 corePoolSize，则将任务加入 BlockingQueue。
   3）如果无法将任务加入 BlockingQueue（队列已满），则创建新的线程来处理任务（注意，执行这一步骤需要获取全局锁）。
   4）如果创建新线程将使当前运行的线程超出 maximumPoolSize，任务将被拒绝，并调用
   RejectedExecutionHandler.rejectedExecution () 方法。
   
   注意：ThreadPoolExecutor 采取上述步骤的总体设计思路，是为了在执行 execute () 方法时，尽可能 地避免获取全局锁（那将会是一个严重的可伸缩瓶颈）。在 ThreadPoolExecutor 完成预热之后 （当前运行的线程数大于等于 corePoolSize），几乎所有的 execute () 方法调用都是执行步骤 2，而步骤 2 不需要获取全局锁。

3. 任务执行

• 线程池创建线程时，会将线程封装成工作线程 Worker，Worker 在执行完任务后，还会循环获取工作队列里的任务来执行。我们可以从 Worker 类的 run () 方法里看到这点。
• 线程池中的线程执行任务分两种情况，如下。
  1）在 execute () 方法中创建一个线程时，会让这个线程执行当前任务。
  2）这个线程执行完上图中 1 的任务后，会反复从 BlockingQueue 获取任务来执行。

二、线程池的使用

1.创建

Java 中创建线程池很简单，只需要调用 Executors 中相应的便捷方法即可，比如

Executors.newFixedThreadPool(int nThreads)，

但是便捷不仅隐藏了复杂性，也为我们埋下了潜在的隐患（OOM，线程耗尽）。小程序使用这些快捷方法没什么问题，对于服务端需要长期运行的程序，创建线程池应该直接使用 ThreadPoolExecutor 的构造方法。没错，上述 Executors 方法创建的线程池就是 ThreadPoolExecutor。

所以我们可以通过 ThreadPoolExecutor 来创建一个线程池。

// Java线程池的完整构造函数
public ThreadPoolExecutor(
  int corePoolSize, // 线程池长期维持的线程数，即使线程处于Idle状态，也不会回收。
  int maximumPoolSize, // 线程数的上限
  long keepAliveTime, TimeUnit unit, // 超过corePoolSize的线程的idle时长，
                                     // 超过这个时间，多余的线程会被回收。
  BlockingQueue<Runnable> workQueue,