java Future 接口介紹

(轉自：http://blog.csdn.net/yangyan19870319/article/details/6093481)

在Java中，若是須要設定代碼執行的最長時間，即超時，能夠用Java線程池ExecutorService類配合Future接口來實現。 Future接口是Java標準API的一部分，在java.util.concurrent包中。Future接口是Java線程Future模式的實現，能夠來進行異步計算。

Future模式能夠這樣來描述：我有一個任務，提交給了Future，Future替我完成這個任務。期間我本身能夠去作任何想作的事情。一段時間以後，我就即可以從Future那兒取出結果。就至關於下了一張定貨單，一段時間後能夠拿着提訂單來提貨，這期間能夠幹別的任何事情。其中Future 接口就是定貨單，真正處理訂單的是Executor類，它根據Future接口的要求來生產產品。

Future接口提供方法來檢測任務是否被執行完，等待任務執行完得到結果，也能夠設置任務執行的超時時間。這個設置超時的方法就是實現Java程序執行超時的關鍵。

Future接口是一個泛型接口，嚴格的格式應該是Future<V>，其中V表明了Future執行的任務返回值的類型。 Future接口的方法介紹以下：

• boolean cancel (boolean mayInterruptIfRunning) 取消任務的執行。參數指定是否當即中斷任務執行，或者等等任務結束
• boolean isCancelled () 任務是否已經取消，任務正常完成前將其取消，則返回 true
• boolean isDone () 任務是否已經完成。須要注意的是若是任務正常終止、異常或取消，都將返回true
• V get () throws InterruptedException, ExecutionException  等待任務執行結束，而後得到V類型的結果。InterruptedException 線程被中斷異常， ExecutionException任務執行異常，若是任務被取消，還會拋出CancellationException
• V get (long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException 同上面的get功能同樣，多了設置超時時間。參數timeout指定超時時間，uint指定時間的單位，在枚舉類TimeUnit中有相關的定義。若是計算超時，將拋出TimeoutException

Future的實現類有java.util.concurrent.FutureTask<V>即 javax.swing.SwingWorker<T,V>。一般使用FutureTask來處理咱們的任務。FutureTask類同時又實現了Runnable接口，因此能夠直接提交給Executor執行。使用FutureTask實現超時執行的代碼以下：

 1 ExecutorService executor = Executors.newSingleThreadExecutor();   
 2 FutureTask<String> future =   
 3        new FutureTask<String>(new Callable<String>() {//使用Callable接口做爲構造參數   
 4          public String call() {   
 5            //真正的任務在這裏執行，這裏的返回值類型爲String，能夠爲任意類型   
 6        }});   
 7 executor.execute(future);   
 8 //在這裏能夠作別的任何事情   
 9 try {   
10     result = future.get(5000, TimeUnit.MILLISECONDS); //取得結果，同時設置超時執行時間爲5秒。一樣能夠用future.get()，不設置執行超時時間取得結果   
11 } catch (InterruptedException e) {   
12     futureTask.cancel(true);   
13 } catch (ExecutionException e) {   
14     futureTask.cancel(true);   
15 } catch (TimeoutException e) {   
16     futureTask.cancel(true);   
17 } finally {   
18     executor.shutdown();   
19 }  

不直接構造Future對象，也可使用ExecutorService.submit方法來得到Future對象，submit方法即支持以 Callable接口類型，也支持Runnable接口做爲參數，具備很大的靈活性。使用示例以下：

1 ExecutorService executor = Executors.newSingleThreadExecutor();   
2 FutureTask<String> future =　executor.submit(   
3    new Callable<String>() {//使用Callable接口做爲構造參數   
4        public String call() {   
5       //真正的任務在這裏執行，這裏的返回值類型爲String，能夠爲任意類型   
6    }});   
7 //在這裏能夠作別的任何事情   
8 //同上面取得結果的代碼 

ExecutorService executor = Executors.newSingleThreadExecutor();
FutureTask<String> future =　executor.submit(
   new Callable<String>() {//使用Callable接口做爲構造參數
       public String call() {
      //真正的任務在這裏執行，這裏的返回值類型爲String，能夠爲任意類型
   }});
//在這裏能夠作別的任何事情
//同上面取得結果的代碼

利用Future接口實現程序執行超時大體用法就這麼多，改天須要研究下Future接口的內部實現，特別是設定執行超時的實現。