《Java并发编程实战》和《Java并发编程的艺术》 Executor框架小结
1、在线程中如何执行任务
（1）任务执行目标：
在正常负载情况下，服务器应用程序要表现出良好的吞吐率和快速的响应性。在负载过载的情况下，应用程序的性能应该是逐渐减低的，而不是直接失败。
要实现高吞吐率和快速的响应，就应该选择清晰的任务边界和明确的任务执行策略。
（2）任务执行策略有：
1）单线程串行执行任务：缺点：无法提高服务器应用程序的吞吐率和快速响应速度
2）根据任务显示创建线程：缺点：无限创建线程太消耗资源；线程的创建和消耗开销高；易造成系统不稳定
3）利用线程池显示创建线程：
2、任务执行框架-Executor框架
早期Java的线程既是工作单元又是执行机制，而从JDK5开始，使用Runnable和Callable表示工作单元（任务）而由Executor框架负责提供任务的执行机制。
Executor框架封装了多种不同的任务执行策略，实现了任务的提交与任务的执行的解耦，还提供了对线程生命周期的管理的支持等。
任务的表示：Runnable和Callable或者FutureTask
（1）Executor框架类图和Java队列类图
（2）线程池
类
线程池
特点
默认等待队列
适用场景
ThreadPoolExecutor
newFixedThreadPool
创建固定长度的线程池 返回通用的
ThreadPoolExecutor*队列LinkedBlockingQueue
适用于为了满足资源管理的需求，而需要限制当前线程数量的场景
适用于负载比较中的服务器…
newCachedThreadPool
创建可缓存的线程池，空闲线程会被回收掉，线程池规模不受限制（即线程池大小不限制）返回通用的ThreadPoolExecutor
SynchronousQueue
适用于执行很多短期异步任务的小程序或者负载较轻的服务器
…
newSingleThreadExecutor
单线程的Executor，创建当个工作者线程来执行任务。
能确保按照任务队列中的顺序执行任务 返回通用的ThreadPoolExecutor*队列LinkedBlockingQueue
适用于需要保证顺序执行各个任务，并且在任意时间点不会有多个线程活动的场景
ScheduleThreadPoolExecutor
newScheduledThreadPool
创建固定的线程池并且以延迟或定时的方式来执行任务
返回ScheduledThreadPoolExecutor*阻塞队列DelayQueue 适用于需要多个线程在后台执行周期性任务，同事为了满足资源管理的需求而现在后台线程的数量的应用场景
适用于需要定时执行任务的场景…
newSingleThreadScheduleThreadPool
创建单个线程以顺序延迟或者定式的方式执行任务
返回ScheduledThreadPoolExecutor*阻塞队列DelayQueue 适用于需要单个线程顺序执行周期性任务的场景
（3）Executor的生命周期(ExecutorService的接口)
Executor通过扩展ExecutorService接口新增了执行服务的生命周期管理方法,
ExecutorService的生命周期有3种状态：运行，关闭，已终止
ExecutorService接口方法介绍
方法名称
作用
返回参数
注意事项
shutdown() 关闭服务，执行平缓的的关闭过程，不再接受新的任务，同时等待所有的任务执行完成（包括已提交但未执行的任务）; void shutdownNow() 立即关闭，并取消所有任务包括正在执行的和未执行的，然后返回已提交但未执行的任务（不包括那些正在执行被关闭的任务）; List<Runnable> isShutdown(): 如果此执行程序已关闭，则返回 true boolean isTerminated(): 如果关闭后所有任务都已完成，则返回 true。注意，除非首先调用 shutdown 或 shutdownNow，否则 isTerminated 永不为 true。 boolean awaitTermination(long timeout,TimeUnit unit) 等待（阻塞）直到关闭或最长等待时间或发生中断
如果此执行程序终止，则返回 true；如果终止前超时期满，则返回 falseboolean execute(Runnable )
提交一个 Runnable 任务用于执行 void submit(Runnable ) 提交一个 Runnable 任务用于执行，并返回一个表示该任务的 Future。该 Future 的 get 方法在成功完成时将会返回给定的结果。
Future<?>
submit(Callable<T> ) 提交一个返回值的任务用于执行，返回一个表示任务的未决结果的 Future。该 Future 的 get 方法在成功完成时将会返回该任务的结果。 Future<T>
invokeAll(Collection<? extends Callable<T>> tasks,long timeout,TimeUnit unit)
执行给定的任务，当所有任务完成或超时期满时（无论哪个首先发生），返回保持任务状态和结果的 Future 列表。返回列表的所有元素的 Future.isDone() 为 true。一旦返回后，即取消尚未完成的任务。
注意，可以正常地或通过抛出异常来终止已完成 任务。如果此操作正在进行时修改了给定的 collection，则此方法的结果是不确定的。List<Future<T>>
表示任务的 Future 列表，列表顺序与给定任务列表的迭代器所生成的顺序相同。
如果操作未超时，则已完成所有任务。如果确实超时了，则某些任务尚未完成。注意1：该方法会一直阻塞直到所有任务完成或超时。
注意2:如果确实超时了，则某些任务尚未完成。【那么这些尚未完成的任务应该被系统取消】invokeAll(Collection<? extends Callable<T>> tasks) 执行给定的任务，当所有任务完成时，返回保持任务状态和结果的 Future 列表。返回列表的所有元素的 Future.isDone() 为 true。
注意，可以正常地或通过抛出异常来终止已完成 任务。如果正在进行此操作时修改了给定的 collection，则此方法的结果是不确定的。List<Future<T>> 执行给定的任务，当所有任务完成时，返回保持任务状态和结果的 Future 列表。返回列表的所有元素的 Future.isDone() 为 true。
注意，可以正常地或通过抛出异常来终止已完成 任务。如果正在进行此操作时修改了给定的 collection，则此方法的结果是不确定的。该方法会一直阻塞直到所有任务完成。
（3）ScheduledThreadPoolExecutor实现延迟任务与周期任务
1）比较实现延迟任务与周期任务的两种方法：
类
特点
适用情况
Timer a.执行所有定时任务时只创建一个线程，任务执行时间过长时破坏其他定时任务的定时精确性
b.不能处理不捕获未处理异常，遇到未检查异常时将终止定时任务，造成“线程泄露”
c.基于绝对时间而不是相对时间的调度机制，任务的执行对系统时钟变化很敏感少用 ScheduledThreadPoolExecutor 能够正确处理执行任务过程中出现的异常
b.基于相对时间的调度推荐使用
2）如何构建自己的调度服务
使用DelayQueue为ScheduledThreadPoolExecutor提供调度功能。DelayQueue管理者一组Delayed对象，每个Delayed对象都有一个相应的延迟时间，每个Delayed对象逾期后才能从DelayQueue中执行take操作。
3、如何提高程序的并行性？找出同构并发执行任务
（1）任务的表示
Runnable：
Callable:可以返回任务执行的结果
（2）同构任务与异构任务
同构任务：并发执行性能提升少
异构任务：并发执行性能提升多
（3）Future与CompletionService
Future：作为单个计算句柄
CompletionService:作为一组计算的句柄，CompletionService将Executor和BlockingQueue的功能融合在一起。
CopletionService<ImageData> completionService=new ExecutorCompletService(executor);
completionService.submit(callable);
completionService.take();
（4）Future.get()与Future.get(TimeOut,TimeUnit)
Future.get() 任务不设时限
Future.get(TimeOut,TimeUnit)为任务设置时限
（5）Executor.invokeAll(List<Task>,TimeOut,TimeUnit)
将多个任务提交到ExecutorService并获得一组结果。