国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 學院 > 開發設計 > 正文

javaFuture接口介紹

2019-11-14 15:15:42
字體:
來源:轉載
供稿:網友

(轉自: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
  • get () throws InterruptedException, ExecutionException  等待任務執行結束,然后獲得V類型的結果。InterruptedException 線程被中斷異常, ExecutionException任務執行異常,如果任務被取消,還會拋出CancellationException
  • 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接口的內部實現,特別是設定執行超時的實現。


發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 白玉县| 安溪县| 清新县| 营口市| 论坛| 喀喇| 嘉鱼县| 西充县| 哈尔滨市| 安龙县| 吴堡县| 台东市| 曲靖市| 德令哈市| 海安县| 虹口区| 沛县| 调兵山市| 肇州县| 交城县| 宜兰县| 陆丰市| 秀山| 开原市| 韶关市| 塔城市| 三门县| 清河县| 壶关县| 永宁县| 泽库县| 二连浩特市| 锡林浩特市| 海口市| 济宁市| 尤溪县| 高邑县| 高台县| 郯城县| 彭山县| 岑溪市|