线程池

线程池可以通过ThreadPoolExecutor来创建，我们来看一下它的构造函数：

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

几个核心参数的作用：

• corePoolSize： 线程池核心线程数最大值
• maximumPoolSize： 线程池最大线程数大小
• keepAliveTime： 线程池中非核心线程空闲的存活时间大小
• unit： 线程空闲存活时间单位
• workQueue： 存放任务的阻塞队列
• threadFactory： 用于设置创建线程的工厂，可以给创建的线程设置有意义的名字，可方便排查问题。

• handler： 线城池的饱和策略事件，主要有四种类型。

  
  image.png

• 提交一个任务，线程池里存活的核心线程数小于线程数corePoolSize时，线程池会创建一个核心线程去处理提交的任务。
• 如果线程池核心线程数已满，即线程数已经等于corePoolSize，一个新提交的任务，会被放进任务队列workQueue排队等待执行。
• 当线程池里面存活的线程数已经等于corePoolSize了,并且任务队列workQueue也满，判断线程数是否达到maximumPoolSize，即最大线程数是否已满，如果没到达，创建一个非核心线程执行提交的任务。
• 如果当前的线程数达到了maximumPoolSize，还有新的任务过来的话，直接采用拒绝策略处理。

四种拒绝策略

• AbortPolicy(抛出一个异常，默认的)
• DiscardPolicy(直接丢弃任务)
• DiscardOldestPolicy（丢弃队列里最老的任务，将当前这个任务继续提交给线程池）
• CallerRunsPolicy（交给线程池调用所在的线程进行处理)

线程池异常处理

如果向线程池提交的线程出现异常，线程池并没有抛出异常，所以我们无法感知任务出现了异常。
线程池异常处理方式：

• 线程内部价try/catch
• 如果是Future，那么可以在future.get()的时候捕获异常
• 给线程池设置线程工厂，里边设置UncaughtExceptionHandler
• 重写ThreadPoolExecutor的afterExecute方法，处理传递的异常引用

线程池的工作队列

• ArrayBlockingQueue 阻塞，有界队列，FIFO排序
  LinkedBlockingQueue 阻塞，无界队列，FIFO排序
  DelayQueue 定时周期的延迟执行的队列
  PriorityBlockingQueue 具有优先级的无界阻塞队列
  SynchronousQueue 不存储元素的阻塞队列，每个插入操作必须等到另一个线程调用移除操作，否则插入操作一直处于阻塞状态

几种常用的线程池

• newFixedThreadPool (固定数目线程的线程池)。
  1 核心线程数和最大线程数大小一样
  2 阻塞队列为无界队列LinkedBlockingQueue
  3 适用执行长期的任务
• newCachedThreadPool(可缓存线程的线程池)
  1 核心线程数为0
  2 最大线程数为Integer.MAX_VALUE
  3 阻塞队列是SynchronousQueue
  4 非核心线程空闲存活时间为60秒
  5 用于并发执行大量短期的小任务
• newSingleThreadExecutor(单线程的线程池)
  1 只有单个线程
  2 阻塞队列是LinkedBlockingQueue
  3 适用于串行执行任务的场景，一个任务一个任务地执行
• newScheduledThreadPool(定时及周期执行的线程池)
  1 最大线程数为Integer.MAX_VALUE
  2 阻塞队列是DelayedWorkQueue
  3 scheduleAtFixedRate() ：按某种速率周期执行
  4 scheduleWithFixedDelay()：在某个延迟后执行
  5 周期性执行任务的场景，需要限制线程数量的场景

线程池状态

image.png

RUNNING

该状态的线程池会接收新任务，并处理阻塞队列中的任务;
调用线程池的shutdown()方法，可以切换到SHUTDOWN状态;
调用线程池的shutdownNow()方法，可以切换到STOP状态;

SHUTDOWN

该状态的线程池不会接收新任务，但会处理阻塞队列中的任务；
队列为空，并且线程池中执行的任务也为空,进入TIDYING状态;

STOP

该状态的线程不会接收新任务，也不会处理阻塞队列中的任务，而且会中断正在运行的任务；
线程池中执行的任务为空,进入TIDYING状态;

TIDYING

该状态表明所有的任务已经运行终止，记录的任务数量为0。
terminated()执行完毕，进入TERMINATED状态

TERMINATED

该状态表示线程池彻底终止