一、线程池的整体类图

（实线是继承 虚线是实现）

1.Executor：线程池顶级接口

2.ExecutorService：线程池次级接口，对Executor做了一些扩展，增加了一些功能

3.ScheduledExecutorService：对ExecutorService做了一些扩展，增加了一些定时任务相关的功能

4.AbstractExecutorService：抽象类，运用模板方法设计模式实现了一部分方法

5.ThreadPoolExecutor：普通线程池类，包含最基本的一些线程池操作相关的方法实现

6.ScheduledThreadPoolExecutor：定时任务线程池类，用于实现定时任务相关的功能

7.ForkJoinPool：新型线程池类，Java7中新增的线程池类，基于工作窃取理论（WorkStealing）实现，运用于大任务拆分为小任务，任务很多的场景

8.Executors：线程池工具类，定义了一些快速实现线程池的方法。

1.Executor

线程池顶级接口，定义了一个执行无返回值任务的方法

2.ExecutorService

Executor定义了如何执行的执行体，Service定义了对于Executor应该提供怎样的服务（这些服务就是线程池的服务）。

3.AbstractExecutorService

（1）submit --> newTaskFor --> FutureTask --> RunnableFuture

    1）Future：代表异步执行的结果
复制代码

代表扔到线程池里面线程的执行体的代理对象，通过Future可以观察里面Runnable的执行状态，进行取消等操作。

    2）为啥RunnableFuture继承了Runnable，自己里面又写了一个Run方法？        
复制代码

有点类似于显性基因和隐性基因。虽然我继承了Runnable，有Run的功能，也就是一个人从人类那里继承了打架的基因，但是实际上他不会打架，而另一个人不仅有打架的这个基因，而且实际上他也确实会打架。也就是写了Run，那我一定就会打架了（显性基因）。

（2）invokeAll

没有超时时间的invokeAll

1）新建了一个任务数量大小的Future数组（也就是代理对象）

2）把线程扔到线程池，并拿到他的代理对象，执行此线程（放到线程池执行，自己保留一个存根）

3）从Future数组中（也就是存根）获取执行结果，没有结果时会一直阻塞等待，直到所有的任务都执行完毕才会继续

4）获取执行结果时出现异常时（取消异常和执行异常忽略），如果是Error或RuntimeException等异常时，会把没有执行的任务全部取消掉（取消操作也是通过代理对象来完成的）

有超时时间的invokeAll

1）先把所有的任务放到Future数组

2）获取当前的系统时间，加上超时时间，即为deadline截止时间

3）挨个执行Future数组里的任务，执行一次，截止时间就减去一次当前的系统时间（相当于就是超时时间减去执行时间），如果减完后的时间小于等于0，返回Future数组（也就是使用带超时时间的invokeAll，如果时间很短，任务不一定都执行了，所以返回的Future数组可能有未执行的任务）

4）挨个获取执行结果。获取的结果如果是任务没有执行完的结果，并且所剩余的超时时间小于等于0，会直接取消所有未执行的任务（源码是取消所有的任务，但是已经执行完的任务，都已经有执行结果了，取消就无意义了）；如果获取的任务未执行，但是还有超时时间，则等待获取。

（3）invokeAny

没有超时时间的invokeAny

1）新建了一个任务数量大小的Future数组

2）new了一个ExecutorCompletionService，并把当前对象（即AbstractExecutorService）传过去

3）通过ecs提交任务，并把结果添加到Future数组中

4）从ecs中拿执行结果，如果为空，并且还有任务没有添加到ecs中，就把任务添加到ecs中，如果所有任务都添加到ecs中了，但是还是没有一个任务执行完毕，则一直阻塞等待

5）从ecs中拿执行结果，如果不为空，则直接返回获取的结果

6）同样，以上在执行过程中，抛出了异常直接把未执行的任务取消

（今天把Executor、ExecutorServer和AbstractExecutorService常用方法介绍完了，按照线程池类图，接下来就是ThreadPoolExecutor了）

作者：monday
链接：https://juejin.cn/post/7046586462527029256