Java并发编程-Executor框架集

标签：

Executor框架集对线程调度进行了封装，将任务提交和任务执行解耦。

它提供了线程生命周期调度的所有方法，大大简化了线程调度和同步的门槛。

Executor框架集的核心类图如下：

从上往下，可以很清晰的看出框架集的各个类，以及它们之间的关系：
Executor，是一个可以提交可执行（Runnable）任务的Object，这个接口解耦了任务提交和执行细节（线程使用、调度等），Executor主要用来替代显示的创建和运行线程；
ExecutorService提供了异步的管理一个或多个线程终止、执行过程(Future)的方法；
AbstractExecutorService提供了ExecutorService的一个默认实现，这个类通过RunnableFuture（实现类FutureTask）实现了submit, invokeAny, invokeAll几个方法；
ThreadPoolExecutor是ExecutorService的一个可配置的线程池实现，它的两个重要的配置参数：corePoolSize（线程池的基本大小，即在没有任务需要执行的时候线程池的大小，并且只有在工作队列满了的情况下才会创建超出这个数量的线程。这里需要注意的是：在刚刚创建ThreadPoolExecutor的时候，线程并不会立即启动，而是要等到有任务提交时才会启动，除非调用了prestartCoreThread/prestartAllCoreThreads事先启动核心线程。再考虑到keepAliveTime和allowCoreThreadTimeOut超时参数的影响，所以没有任务需要执行的时候，线程池的大小不一定是corePoolSize。）, maximumPoolSize（线程池中允许的最大线程数，线程池中的当前线程数目不会超过该值。如果队列中任务已满，并且当前线程个数小于maximumPoolSize，那么会创建新的线程来执行任务。这里值得一提的是largestPoolSize，该变量记录了线程池在整个生命周期中曾经出现的最大线程个数。为什么说是曾经呢？因为线程池创建之后，可以调用setMaximumPoolSize() 改变运行的最大线程的数目。）；
ScheduledExecutorService 是添加了调度特性（延迟或者定时执行）的ExecutorService；
ScheduledThreadPoolExecutor是具有调度特性的ExecutorService的池化实现；
Executors是一个Executor, ExecutorService, ScheduledExecutorService, ThreadFactory, Callable的工具类，它能满足大部分的日常应用场景。使用它创建线程池：

Java并发编程-Executor框架集

标签：

原文地址：http://www.cnblogs.com/suxuan/p/4948767.html