java SE5的java.util.concurrent包中的執(zhí)行器（Executor）將為你管理Thread對象，從而簡化了并發(fā)編程。Executor引入了一些功能類來管理和使用線程Thread，其中包括ThreadPoolExecutor (線程池)，Executor，Executors，ExecutorService，CompletionService，F(xiàn)uture，Callable等

Executor的子接口有：ExecutorService,ScheduledExecutorService,已知實(shí)現(xiàn)類：AbstractExecutorService,ScheduledThreadPoolExecutor, ThreadPoolExecutor。

Executor是Java線程池的頂級接口 

Executors是一個類

      Executors類提供了若干個靜態(tài)方法，用于生成不同類型的線程池：

一、創(chuàng)建線程池

         并發(fā)編程的一種編程方式是把任務(wù)拆分為一些列的小任務(wù)，即Runnable，然后在提交給一個Executor執(zhí)行，Executor.execute(Runnalbe) 。Executor在執(zhí)行時使用內(nèi)部的線程池完成操作。

Executors類，提供了一系列工廠方法用于創(chuàng)先線程池，返回的線程池都實(shí)現(xiàn)了ExecutorService接口。

Java通過Executors提供四種線程池，分別為：newCachedThreadPool 創(chuàng)建一個可緩存線程池，如果線程池長度超過處理需要，可靈活回收空閑線程，若無可回收，則新建線程。newFixedThreadPool創(chuàng)建一個定長線程池，可控制線程最大并發(fā)數(shù)，超出的線程會在隊列中等待。newScheduledThreadPool 創(chuàng)建一個定長線程池，支持定時及周期性任務(wù)執(zhí)行。newSingleThreadExecutor 創(chuàng)建一個單線程化的線程池，它只會用唯一的工作線程來執(zhí)行任務(wù)，保證所有任務(wù)按照指定順序(FIFO, LIFO, 優(yōu)先級)執(zhí)行。

二、ExecutorService與生命周期

三、使用Callable，F(xiàn)uture返回結(jié)果

Callable和Runnable的區(qū)別如下：

I    Callable定義的方法是call，而Runnable定義的方法是run。

II   Callable的call方法可以有返回值，而Runnable的run方法不能有返回值。

III  Callable的call方法可拋出異常，而Runnable的run方法不能拋出異常。

/**

 * Callable 和 Future接口

 * Callable是類似于Runnable的接口，實(shí)現(xiàn)Callable接口的類和實(shí)現(xiàn)Runnable的類都是可被其它線程執(zhí)行的任務(wù)。

 * Callable和Runnable有幾點(diǎn)不同：

 * （1）Callable規(guī)定的方法是call()，而Runnable規(guī)定的方法是run().

 * （2）Callable的任務(wù)執(zhí)行后可返回值，而Runnable的任務(wù)是不能返回值的。

 * （3）call()方法可拋出異常，而run()方法是不能拋出異常的。

 * （4）運(yùn)行Callable任務(wù)可拿到一個Future對象，

 * Future 表示異步計算的結(jié)果。它提供了檢查計算是否完成的方法，以等待計算的完成，并檢索計算的結(jié)果。

 * 通過Future對象可了解任務(wù)執(zhí)行情況，可取消任務(wù)的執(zhí)行，還可獲取任務(wù)執(zhí)行的結(jié)果。

 */

 // 定義3個Callable類型的任務(wù)  MyCallable實(shí)現(xiàn)了Callable 接口

        MyCallable task1 = new MyCallable(0);

        MyCallable task2 = new MyCallable(1);

        MyCallable task3 = new MyCallable(2);

       // 創(chuàng)建一個執(zhí)行任務(wù)的服務(wù)

        ExecutorService es = Executors.newFixedThreadPool(3);

 try {

           // 提交并執(zhí)行任務(wù)，任務(wù)啟動時返回了一個Future對象，

            // 如果想得到任務(wù)執(zhí)行的結(jié)果或者是異常可對這個Future對象進(jìn)行操作

            Future future1 = es.submit(task1);

           // 獲得第一個任務(wù)的結(jié)果，如果調(diào)用get方法，當(dāng)前線程會等待任務(wù)執(zhí)行完畢后才往下執(zhí)行

            System.out.PRintln("task1: " + future1.get());

            Future future2 = es.submit(task2);

           // 等待5秒后，再停止第二個任務(wù)。因?yàn)榈诙€任務(wù)進(jìn)行的是無限循環(huán)

            Thread.sleep(5000);

            System.out.println("task2 cancel: " + future2.cancel(true));

           // 獲取第三個任務(wù)的輸出，因?yàn)閳?zhí)行第三個任務(wù)會引起異常

            // 所以下面的語句將引起異常的拋出

            Future future3 = es.submit(task3);

            System.out.println("task3: " + future3.get());

        } catch (Exception e){

            System.out.println(e.toString());

        }

   // 停止任務(wù)執(zhí)行服務(wù)

        es.shutdownNow();