Java并发编程的相关知识(12)--Executor框架
Executor框架
Java的线程即是工作单元,也是执行机制。从JDK 5开始,把工作单元与执行机制分离开来,工作单元包括Runnable和Callable,而执行机制由Executor框架提供。
在上层,java多线程程序通常把应用分解为若干个任务,然后使用用户级的调度器将这些任务映射为固定数量的线程;在底层,操作系统内核将这些线程映射到硬件处理器上。
Executor框架的结构
Executor框架主要由3大部分组成
- 任务,包括被执行任务需要实现的接口:Runnable接口或Callable接口。
- 任务的执行。包括任务执行机制的核心接口Executor,以及继承Executor的ExecutorService接口。
- 异步计算的结果。包括接口Future和实现Future接口的FutureTask类。
Executor框架的主要成员:ThreadPoolExecutor,ScheduledThreadPoolexecutor,Future接口,Runnable接口,Callable接口和Executors。
ThreadPoolExecutor
ThreadPoolExecutors通常使用工厂类Executors来创建。Executors可以创建3种类型的ThreadPoolExecutor
FixedThreadPool
适用于为了满足资源管理的需求,而需要限制当前线程数量的应用场景,它适用于负载比较重的服务器。
SingleThreadExecutor
创建使用单个线程的SingleThreadExecutor的API,适用于需要保证顺序的执行各个人物,并且在任意时间点,不会有多个线程是活动的应用场景。
CachedThreadPool
是一个大小无界的线程池,适用于执行很多的短期异步任务的小程序,或者是负载较轻的服务器。
ScheduledThreadPoolExecutor
通常使用工厂类Executors来创建,可以分为两类
ScheduledThreadPoolExecutor
包含若干个线程的ScheduledThreadPoolExecutor,适用于需要多个后台线程执行周期任务,同时为了满足资源管理的需求而需要限制后台线程的数量的应用场景。
SingleThreadScheduledExecutor
包含一个线程的SingleThreadScheduledExecutor,适用于单个后台线程执行周期任务,同时需要保证顺序地执行各个任务的应用场景。
Future接口
当我们把Runnable接口或Callable接口的实现类提交给ThreadPoolExecutor或ScheduledThreadPoolExecutor时,它们会想我们返回一个FutureTask对象。
Runnable接口和Callable接口
Runnable接口和Callable接口的实现类都可以被ThreadPoolExecutor或ScheduledThreadPoolExecutor执行,它们之间的区别是Runnable不会返回结果,而Callable可以返回结果。