Executor接口實現(xiàn)線程池管理

從JDK5開始，在java.util.concurrent包下增加了Executor接口及其子類，允許使用線程池技術(shù)來管理線程并發(fā)問題。Executor接口提供了一個常用的ExecutorService子接口，通過該子接口可以很方便地進行線程池管理。

通過Executor接口實現(xiàn)線程池管理的主要步驟如下：

（1)創(chuàng)建一個實現(xiàn)Runnable接口或者Callable接口的實現(xiàn)類，同時重寫run(）或者call（）方法；

（2）創(chuàng)建Runnable接口或者Callable接口的實現(xiàn)類對象；

（3）使用Executors線程執(zhí)行器類創(chuàng)建線程池；

（4）使用ExecutorService執(zhí)行器服務類的submit（）方法將Runnable接口或者Callable接口的實現(xiàn)類對象提交到線程池進行管理；

（5）線程任務執(zhí)行完成后，可以使用shutdown（）方法關(guān)閉線程池。

接下來通過一個案例來演示如何通過Executor接口來實現(xiàn)線程池管理，如例10-18所示。

例10-18 Example18.java

import java.util.concurrent.*;
//1.定義一個實現(xiàn)Callable接口的實現(xiàn)類
class MyThread4 implements Callable<Object>{
    //1.1重寫callable接口的cal1（）方法
    public Object call () throwa Exception {
        int i=0;
        while (i++<5)(
            System.out.println(Thread.currentThread().getName()
                               +“的cal1（）方法在運行“）；
        }
        return 1;
     } 
 }
public class Examplel8 {
   public static void main(String[] args) throws InterruptedException,
                                                 ExecutionException (
       //2.創(chuàng)建Callable接口的實現(xiàn)類對象
       MyThread4 myThread4 =new MyThread4();
       //3.使用Executors線程執(zhí)行器類創(chuàng)建可擴展的線程池
       ExecutorService executor =Executors.newCachedThreadPool () ;
       //4.將cal1able接口實現(xiàn)類對象提交到線程池進行管理
       Future<Object>resultl=executor.submit(myThread4);
       Future<Object>result2=executor.submit(myThread4);
       //5.關(guān)閉線程池
       executor. shutdown ();
       //對于有返回值的線程任務，獲取執(zhí)行結(jié)果
       System.out.println("thread-1返回結(jié)果："+result1.get());
       System.out.println("thread-2返回結(jié)果："+result2.get())；
   }
}

從圖10-22可以看出，例10-18所示的案例創(chuàng)建了一個自定義的線程池executor(線程池默認生成名稱為pool-1），在該線程池中管理有兩個默認生成名稱的線程thread-1和thread-2，同時還可以獲取這兩個線程的執(zhí)行結(jié)果。

在例10-18所示的案例中，線程池是通過Executors的newCachedThreadPool（）方法創(chuàng)建的，Executors是JDK5中增加的線程執(zhí)行器工具類，提供了4種方法來創(chuàng)建用于不同需求的線程池，如表10-4所示。