从Java5开始，JDK并发API提供了ThreadPoolExecutor类，用来创建线程池。合理的使用线程池，有以下三个好处：

• 降低资源消耗
• 提高响应速度
• 提高线程的可管理性

ThreadPoolExecutor

构造方法

基本构造方法

创建大小固定的线程池

创建大小为1的线程池

常用方法

• void executeTask(Runnable command)，执行Runnable任务
• void shutdown()，关闭线程池
• int getPoolSize()，获取线程池大小
• int getActiveCount()，获取正在运行的线程数量
• long getCompletedTaskCount()，获取已完成的任务数量
• Future<T> submit(Callable<T> task)，执行Callable任务
• T invokeAny(Collection<? extends Callable<T>> tasks)，执行一组Callable任务，只获取第一个返回结果
• List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)，执行一组Callable任务，获取全部返回结果

ScheduledThreadPoolExecutor

构造方法

常用方法

• ScheduledFuture schedule(Runnable(or Callable) command, long delay, TimeUnit unit)，延迟运行任务
• boolean awaitTermination(long timeout, TimeUnit unit)，等待一段时间后终结线程池
• ScheduledFuture<?> scheduleAtFixedRate(Runnable command, long initialDelay, long period,TimeUnit unit)，定期的执行任务

Future<T>

Callable<T>任务与Runable任务的最大不同之处就在于Callable<T>任务有返回值，其返回值为Future类型，见上文。

常用方法

• T get()，获取Callable<T>的返回值
• boolean cancel(boolean mayInterruptIfRunning)，取消Callable<T>任务执行
• boolean isCancelled()，是否已取消
• boolean isDone()，是否已完成

FutureTask<T>

FutureTask<T>对Runable或Callable<T>进行了一层封装，并添加了一些方法，如void done()方法。该方法会在任务执行结束后调用，默认情况下该方法是空的，需要Override来定制自己的行为。FutureTask任务可通过线程池的submit(Runable task)方法来执行。

CompletionService<T>

当使用线程池执行任务并获取返回值时，若需要将执行的代码和处理返回值的代码进行分离，可以用CompletionService<T>来进行处理。

常用方法

• Future submit(Callable task)，提交Callable任务
• Future submit(Runnable task, V result)，提交Runnable任务
• Future take()，获取结果，若无结果则等待
• Future poll()，获取结果，若无结果则返回null

RejectedExecutionHandler

线程池在执行shutdown()方法后，将不在接收新的任务，当现有任务全部运行完毕后线程池也将随着关闭，在此期间提交的任务会被线程池拒绝。线程池可以通过设置RejectedExecutionHandler来处理这些被拒绝的任务。

线程池通过void setRejectedExecutionHandler(RejectedExecutionHandler handler)方法来设置处理拒绝任务的类。

RejectedExecutionHandler为接口，需要自己实现该接口并实现唯一的方法void rejectedExecution(Runnable r, ThreadPoolExecutor executor)，其中Runnable对象为被拒绝的任务，ThreadPoolExecutor为线程池对象。