public static ExecutorService newSingleThreadExecutor() {
  return new FinalizableDelegatedExecutorService
    (new ThreadPoolExecutor(1, 1,
                            0L, TimeUnit.MILLISECONDS,
                            new LinkedBlockingQueue<Runnable>()));
}

ThreadPoolExecutor 类

七大参数

ThreadPoolExecutor类主要有以下七个参数：

• int corePoolSize: 核心线程池大小
• int maximumPoolSize: 最大核心线程池大小
• long keepAliveTime: 线程空闲后的存活时间
• TimeUnit unit: 超时单位
• BlockingQueue<Runnable> workQueue: 阻塞队列
• ThreadFactory threadFactory: 线程工厂：创建线程的，一般默认
• RejectedExecutionHandler handle: 拒绝策略

四种拒绝策略

拒绝策略就是当队列满时，线程如何去处理新来的任务。

Java内置了四种拒绝策略：

• ThreadPoolExecutor.CallerRunsPolicy()

• ThreadPoolExecutor.AbortPolicy()

• ThreadPoolExecutor.DiscardPolicy()

• ThreadPoolExecutor.DiscardOldestPolicy()

CallerRunsPolicy（调用者运行策略）

功能：只要线程池没有关闭，就由提交任务的当前线程处理。

使用场景：一般在不允许失败、对性能要求不高、并发量较小的场景下使用。

AbortPolicy（中止策略）

功能：当触发拒绝策略时，直接抛出拒绝执行的异常

使用场景：ThreadPoolExecutor中默认的策略就是AbortPolicy，由于ExecutorService接口的系列ThreadPoolExecutor都没有显示的设置拒绝策略，所以默认的都是这个。

DiscardPolicy（丢弃策略）

功能：直接丢弃这个任务，不触发任何动作

使用场景：提交的任务无关紧要，一般用的少。

DiscardOldestPolicy（弃老策略）

功能：弹出队列头部的元素，然后尝试执行，相当于排队的时候把第一个人打死，然后自己代替

使用场景：发布消息、修改消息类似场景。当老消息还未执行，此时新的消息又来了，这时未执行的消息的版本比现在提交的消息版本要低就可以被丢弃了。

线程池中的状态

• RUNNING 自然是运行状态，指可以接受任务执行队列里的任务
• SHUTDOWN 指调用了 shutdown() 方法，不再接受新任务了，但是队列里的任务得执行完毕。
• STOP 指调用了 shutdownNow() 方法，不再接受新任务，同时抛弃阻塞队列里的所有任务并中断所有正在执行任务。
• TIDYING 所有任务都执行完毕，在调用 shutdown()/shutdownNow() 中都会尝试更新为这个状态。
• TERMINATED 终止状态，当执行 terminated() 后会更新为这个状态。

处理流程

提交一个任务到线程池中，线程池的处理流程如下：

• 判断线程池里的核心线程是否都在执行任务

  • 是：进入下个流程。
  • 否：调用/创建一个新的核心线程来执行任务。

• 线程池判断工作队列是否已满

  • 是：进入下个流程。
  • 否：将新提交的任务存储在这个工作队列里。

• 判断线程池里的所有线程是否都处于工作状态

  • 是：交给拒绝策略来处理这个任务。
  • 否：调用/创建一个新的工作线程来执行任务。

具体使用

创建

不过最好不要使用Executors来创建线程，原因如下（参考自——阿里巴巴Java开发手册）：

• FixedThreadPool 和 SingleThreadPool： 允许的请求队列长度为 Integer.MAX_VALUE，可能会堆积大量的请求，从而导致 OOM
• CachedThreadPool： 允许的创建线程数量为 Integer.MAX_VALUE，可能会创建大量的线程，从而导致 OOM

推荐使用ThreadPoolExecutor类自行创建

// 自定义线程池
ExecutorService threadPool = new ThreadPoolExecutor(
  2,
  Runtime.getRuntime().availableProcessors(),//CPU的核心数，适合CPU密集型任务
  3,
  TimeUnit.SECONDS,
  new LinkedBlockingDeque<>(3),
  Executors.defaultThreadFactory(),
  new ThreadPoolExecutor.DiscardOldestPolicy());