ExecutorService:

它也是一个接口，它扩展自Executor接口，Executor接口更像一个抽象的命令模式，仅有一个方法:execute(runnable);Executor接口简单，可是非常重要，重要在这样的设计的模式上。。Java5以后，通过Executor来启动线程比用Thread的start()更好。在新特征中，能够非常easy控制线程的启动、运行和关闭过程，还能够非常easy使用线程池的特性。

几种不同的ExecutorService线程池对象 

1.newCachedThreadPool() 
-缓存型池子，先查看池中有没有曾经建立的线程，假设有，就reuse.假设没有，就建一个新的线程增加池中 
-能reuse的线程，必须是timeout IDLE内的池中线程，缺省timeout是60s,超过这个IDLE时长，线程实例将被终止及移出池。 
  注意，放入CachedThreadPool的线程不必操心其结束，超过TIMEOUT不活动，其会自己主动被终止。 
2. newFixedThreadPool 
-newFixedThreadPool与cacheThreadPool差点儿相同，也是能reuse就用，但不能随时建新的线程 
-其独特之处:随意时间点，最多仅仅能有固定数目的活动线程存在，此时假设有新的线程要建立，仅仅能放在另外的队列中等待，直到当前的线程中某个线程终止直接被移出池子 
-和cacheThreadPool不同，FixedThreadPool没有IDLE机制（可能也有，但既然文档没提，肯定非常长，类似依赖上层的TCP或UDP IDLE机制之类的），所以FixedThreadPool多数针对一些非常稳定非常固定的正规并发线程，多用于server 
-从方法的源码看，cache池和fixed 池调用的是同一个底层池，仅仅只是參数不同: 
fixed池线程数固定，而且是0秒IDLE（无IDLE） 
cache池线程数支持0-Integer.MAX_VALUE(显然全然没考虑主机的资源承受能力），60秒IDLE  

3.ScheduledThreadPool 
-调度型线程池 
-这个池子里的线程能够按schedule依次delay运行，或周期运行 

是一个接口，继承了Executor:

public interface ExecutorService extends Executor {
}

而Executor亦是一个接口，该接口仅仅包括了一个方法：

void execute(Runnable command);

该类是一个辅助类，此包中所定义的 Executor、ExecutorService、ScheduledExecutorService、ThreadFactory 和 Callable 类的工厂和有用方法。

此类支持下面各种方法：

newFixedThreadPool()

创建一个可重用固定线程数的线程池，以共享的*队列方式来执行这些线程。

void shutdown()

启动一次顺序关闭，运行曾经提交的任务，但不接受新任务。假设已经关闭，则调用没有其它作用。

boolean awaitTermination(long timeout,
                         TimeUnit unit)
                         throws InterruptedException

请求关闭、发生超时或者当前线程中断，不管哪一个首先发生之后，都将导致堵塞，直到全部任务完毕运行。既是等待全部子线程运行结束。

void execute(Runnable command)

在未来某个时间运行给定的命令。该命令可能在新的线程、已入池的线程或者正调用的线程中运行，这由 Executor 实现决定。

Future<?> submit(Runnable task)

提交一个 Runnable 任务用于运行，并返回一个表示该任务的 Future。该 Future 的 get 方法在成功 完毕时将会返回 null。

public class ExecutorServiceTest {

    public static void main(String[] args) throws IOException, InterruptedException {
        // 创建一个固定大小的线程池
        ExecutorService service = Executors.newFixedThreadPool(3);
        for (int i = 0; i < 10; i++) {
            System.out.println("创建线程" + i);
            Runnable run = new Runnable() {
                @Override
                public void run() {
                    System.out.println("启动线程");
                }
            };
            // 在未来某个时间运行给定的命令
            service.execute(run);
        }
        // 关闭启动线程
        service.shutdown();
        // 等待子线程结束，再继续运行以下的代码
        service.awaitTermination(Long.MAX_VALUE, TimeUnit.DAYS);
        System.out.println("all thread complete");
    }
}

能够发现线程被循环创建，可是启动线程却不是连续的，而是由ExecutorService决定的。

參考：http://www.itzhai.com/the-executorservice-common-method-newfixedthreadpool-of-create-fixed-size-thread-pool.html

如有问题请留言，转载注明出处。