java Future 接口使用方法詳解

更新時間：2017年03月02日 11:29:26 投稿：lqh

這篇文章主要介紹了java Future 接口使用方法詳解，F(xiàn)uture接口是Java線程Future模式的實現(xiàn)，可以來進行異步計算的相關(guān)資料,需要的朋友可以參考下

java Future 接口使用方法詳解

在Java中，如果需要設定代碼執(zhí)行的最長時間，即超時，可以用Java線程池ExecutorService類配合Future接口來實現(xiàn)。 Future接口是Java標準API的一部分，在java.util.concurrent包中。Future接口是Java線程Future模式的實現(xiàn)，可以來進行異步計算。
Future模式可以這樣來描述：我有一個任務，提交給了Future，F(xiàn)uture替我完成這個任務。期間我自己可以去做任何想做的事情。一段時間之后，我就便可以從Future那兒取出結(jié)果。就相當于下了一張訂貨單，一段時間后可以拿著提訂單來提貨，這期間可以干別的任何事情。其中Future 接口就是訂貨單，真正處理訂單的是Executor類，它根據(jù)Future接口的要求來生產(chǎn)產(chǎn)品。
Future接口提供方法來檢測任務是否被執(zhí)行完，等待任務執(zhí)行完獲得結(jié)果，也可以設置任務執(zhí)行的超時時間。這個設置超時的方法就是實現(xiàn)Java程序執(zhí)行超時的關(guān)鍵。

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

boolean cancel (boolean mayInterruptIfRunning) 取消任務的執(zhí)行。參數(shù)指定是否立即中斷任務執(zhí)行，或者等等任務結(jié)束
boolean isCancelled () 任務是否已經(jīng)取消，任務正常完成前將其取消，則返回 true
boolean isDone () 任務是否已經(jīng)完成。需要注意的是如果任務正常終止、異?；蛉∠紝⒎祷豻rue
V get () throws InterruptedException, ExecutionException 等待任務執(zhí)行結(jié)束，然后獲得V類型的結(jié)果。InterruptedException 線程被中斷異常， ExecutionException任務執(zhí)行異常，如果任務被取消，還會拋出CancellationException
V get (long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException 同上面的get功能一樣，多了設置超時時間。參數(shù)timeout指定超時時間，uint指定時間的單位，在枚舉類TimeUnit中有相關(guān)的定義。如果計算超時，將拋出TimeoutException

Future的實現(xiàn)類有java.util.concurrent.FutureTask<V>即 javax.swing.SwingWorker<T,V>。通常使用FutureTask來處理我們的任務。FutureTask類同時又實現(xiàn)了Runnable接口，所以可以直接提交給Executor執(zhí)行。使用FutureTask實現(xiàn)超時執(zhí)行的代碼如下：

ExecutorService executor = Executors.newSingleThreadExecutor();  
FutureTask<String> future =  
    new FutureTask<String>(new Callable<String>() {//使用Callable接口作為構(gòu)造參數(shù)  
     public String call() {  
      //真正的任務在這里執(zhí)行，這里的返回值類型為String，可以為任意類型  
    }});  
executor.execute(future);  
//在這里可以做別的任何事情  
try {  
  result = future.get(5000, TimeUnit.MILLISECONDS); //取得結(jié)果，同時設置超時執(zhí)行時間為5秒。同樣可以用future.get()，不設置執(zhí)行超時時間取得結(jié)果  
} catch (InterruptedException e) {  
  futureTask.cancel(true);  
} catch (ExecutionException e) {  
  futureTask.cancel(true);  
} catch (TimeoutException e) {  
  futureTask.cancel(true);  
} finally {  
  executor.shutdown();  
}

ExecutorService executor = Executors.newSingleThreadExecutor(); 
FutureTask<String> future = 
    new FutureTask<String>(new Callable<String>() {//使用Callable接口作為構(gòu)造參數(shù) 
     public String call() { 
      //真正的任務在這里執(zhí)行，這里的返回值類型為String，可以為任意類型 
    }}); 
executor.execute(future); 
//在這里可以做別的任何事情 
try { 
  result = future.get(5000, TimeUnit.MILLISECONDS); //取得結(jié)果，同時設置超時執(zhí)行時間為5秒。同樣可以用future.get()，不設置執(zhí)行超時時間取得結(jié)果 
} catch (InterruptedException e) { 
  futureTask.cancel(true); 
} catch (ExecutionException e) { 
  futureTask.cancel(true); 
} catch (TimeoutException e) { 
  futureTask.cancel(true); 
} finally { 
  executor.shutdown(); 
}

不直接構(gòu)造Future對象，也可以使用ExecutorService.submit方法來獲得Future對象，submit方法即支持以 Callable接口類型，也支持Runnable接口作為參數(shù)，具有很大的靈活性。使用示例如下：

ExecutorService executor = Executors.newSingleThreadExecutor();  
FutureTask<String> future =　executor.submit(  
  new Callable<String>() {//使用Callable接口作為構(gòu)造參數(shù)  
    public String call() {  
   //真正的任務在這里執(zhí)行，這里的返回值類型為String，可以為任意類型  
  }});  
//在這里可以做別的任何事情  
//同上面取得結(jié)果的代碼

ExecutorService executor = Executors.newSingleThreadExecutor(); 
FutureTask<String> future =　executor.submit( 
  new Callable<String>() {//使用Callable接口作為構(gòu)造參數(shù) 
    public String call() { 
   //真正的任務在這里執(zhí)行，這里的返回值類型為String，可以為任意類型 
  }}); 
//在這里可以做別的任何事情 
//同上面取得結(jié)果的代碼

利用Future接口實現(xiàn)程序執(zhí)行超時大致用法就這么多，改天需要研究下Future接口的內(nèi)部實現(xiàn)，特別是設定執(zhí)行超時的實現(xiàn)。

感謝閱讀，希望能幫助到大家，謝謝大家對本站的支持！

您可能感興趣的文章: