Java并发编程系列 -- Executor 框架介绍

前面详细通过源码解释了ThreadPoolExecutor类的运行原理，本篇文章来说一下Executor的框架组成。

Java的线程既是工作单元也是执行单元，从JDK5开始，把工作单元与执行机制分离开来，工作单元包括Runnable和Callable,而执行机制由Executor框架提供。Executor作为一个灵活且强大的异步执行框架，其支持多种不同类型的任务执行策略，提供了一种标准的方法将任务的提交过程和执行过程进行了解耦开发，基于生产者和消费者模型，还提供了对生命周期的支持，以及统计信息收集，应用程序管理机制和性能检测等机制。

Executor框架的结构

Executor框架主要由3大部分组成如下：

• 任务 ：执行任务需要实现的接口：Runnable | Callable 接口
• 任务的执行： 任何执行机制的核心接口是Executor，以及继承了Executor接口的ExecutorService接口，主要的执行者是实现了Executor接口的两个实现类 ThreadPoolExecutor和ScheduledThreadPoolExecutor.
• 异步计算的结果： 包括接口Future和实现Future接口的FutureTask类。

Executor框架包含的主要类和接口如下图：

Executor主要类和接口

Executor执行流程如下：

image.png
首先主线程创建任务，任务需要实现Runnable或者Callable接口，然后执行execute()方法或者submit方法，提交到线程池中。 如果任务实现的是Runnable接口，线程池运行完任务后就结束了，如果任务实现的Callable接口，则需要将任务执行的接口返回，主线程通过get()或者cancle()方法获取任务的返回值，或者取消执行任务。

上面梳理类Executor框架的主要类和接口，下面对主要的类和接口做一个解释：

• Executor：它是一个接口，也是整个Executor框架的基础，只定义了一个方法execute() ,接受Runnable类型的参数。 作用是将任务的提交和任务的执行分离了出来。
• ThreadPoolExector ：是线程池的核心用来执行提交的任务。
• ScheduledThreadPoolExector：继承了ThreadPoolExector类，实现了ScheduledExecutorService接口，可以执行定时任务，在给定的延迟后运行命令，或者周期性运行命令。
• FutureTask：代表异步运算执行的结果
• Runnable和Callable接口的实现类，代表需要执行的任务

Executor框架的主要成员

ThreadPoolExecutor , ScheduledThreadPoolExecutor,Future接口，Runnable接口，Callable接口和Executors是Executor框架的主要成员，下面进行具体的分析：

ThreadPoolExector 通常使用工厂类Executors类创建，可以创建如下3中类型：

• SingleThreadPoolExector：创建使用单线程数量的线程池，适用于保证顺序地执行各个任务，并且在任意时间点，不会有多个活动的应用场景
• FixedThreadPoolExecutor：创建固定线程数量的线程池，适用于满足资源管理的需求，而需要限制当前线程数量的应用场景，它适用于负载比较重的服务器。
• CachedThreadPoolExecutor：根据需要创建新线程的线程池，大小无界的线程池，适用于执行很多短期异步任务的小程序，或者负载比较轻的服务器。

ScheduledThreadPoolExecutor

• ScheduledThreadPoolExecutor：包含若干个线程。需要多个后台线程执行周期任务，同时为了满足资源管理的需求而需要限制后台线程的数量的应用场景。
• SingleThreadScheduledExecutor：只包含一个线程。需要单个后台线程周期性的执行任务，同时需要保证顺序的执行各个人物的应用场景。

Future接口

• 实现Future接口和实现Future接口的FutureTask类用来表示异步计算的结果。

Runnable和Callable接口

• 实现两个接口的实现类，都可以被线程池执行。Runnable和Callable两个接口的区别是前者不会返回结果后者会返回结果。

参考：
书籍：《JAVA并发编程艺术 - 方腾飞》