深刻浅出 Java Concurrency (28): 线程池 part 1 简介[转]

从这一节开始正式进入线程池的部分。其实整个体系已经拖了很长的时间，所以后面的章节会加快速度，甚至只是一个半成品或者简单化，之后有时间的慢慢补充、完善。

其实线程池是并发包里面很重要的一部分，在实际状况中也是使用不少的一个重要组件。

下图描述的是线程池API的一部分。广义上的完整线程池可能还包括Thread/Runnable、Timer/TimerTask等部分。这里只介绍主要的和高级的API以及架构和原理。

 

 

 

大多数并发应用程序是围绕执行任务（Task）进行管理的。所谓任务就是抽象、离散的工做单元（unit of work）。把一个应用程序的工做（work）分离到任务中，能够简化程序的管理；这种分离还在不一样事物间划分了天然的分界线，能够方便程序在出现错误时进行恢复；同时这种分离还能够为并行工做提供一个天然的结构，有利于提升程序的并发性。^[1]

 

并发执行任务的一个很重要前提是拆分任务。把一个大的过程或者任务拆分红不少小的工做单元，每个工做单元可能相关、也可能无关，这些单元在必定程度上能够充分利用CPU的特性并发的执行，从而提升并发性（性能、响应时间、吞吐量等）。

所谓的任务拆分就是肯定每个执行任务（工做单元）的边界。理想状况下独立的工做单元有最大的吞吐量，这些工做单元不依赖于其它工做单元的状态、结果或者其余资源等。所以将任务尽量的拆分红一个个独立的工做单元有利于提升程序的并发性。

对于有依赖关系以及资源竞争的工做单元就涉及到任务的调度和负载均衡。工做单元的状态、结果或者其余资源等有关联的工做单元就须要有一个整体的调度者来协调资源和执行顺序。一样在有限的资源状况下，大量的任务也须要一个协调各个工做单元的调度者。这就涉及到任务执行的策略问题。

任务的执行策略包括4W3H部分：

• 任务在什么（What）线程中执行
• 任务以什么（What）顺序执行（FIFO/LIFO/优先级等）
• 同时有多少个（How Many）任务并发执行
• 容许有多少个（How Many）个任务进入执行队列
• 系统过载时选择放弃哪个（Which）任务，如何（How）通知应用程序这个动做
• 任务执行的开始、结束应该作什么（What）处理

在后面的章节中会详细分写这些策略是如何实现的。咱们先来简单回答些如何知足上面的条件。

1. 首先明确必定是在Java里面能够供使用者调用的启动线程类是Thread。所以Runnable或者Timer/TimerTask等都是要依赖Thread来启动的，所以在ThreadPool里面一样也是靠Thread来启动多线程的。
2. 默认状况下Runnable接口执行完毕后是不能拿到执行结果的，所以在ThreadPool里就定义了一个Callable接口来处理执行结果。
3. 为了异步阻塞的获取结果，Future能够帮助调用线程获取执行结果。
4. Executor解决了向线程池提交任务的入口问题，同时ScheduledExecutorService解决了如何进行重复调用任务的问题。
5. CompletionService解决了如何按照执行完毕的顺序获取结果的问题，这在某些状况下能够提升任务执行的并发，调用线程没必要在长时间任务上等待过多时间。
6. 显然线程的数量是有限的，并且也不宜过多，所以合适的任务队列是必不可少的，BlockingQueue的容量正好能够解决此问题。
7. 固定任务容量就意味着在容量满了之后须要必定的策略来处理过多的任务（新任务），RejectedExecutionHandler正好解决此问题。
8. 必定时间内阻塞就意味着有超时，所以TimeoutException就是为了描述这种现象。TimeUnit是为了描述超时时间方便的一个时间单元枚举类。
9. 有上述问题就意味了配置一个合适的线程池是很复杂的，所以Executors默认的一些线程池配置能够减小这个操做。

线程池的基本策略大体就这些，从下一节开始就从线程池的基本原理和执行方法开始描述。

 

[1] Java Concurrency in Practice