Future模式能夠這樣來描述:我有一個任務,提交給了Future,Future替我完成這個任務。期間我本身能夠去作任何想作的事情。一段時 間以後,我就即可以從Future那兒取出結果。就至關於下了一張定貨單,一段時間後能夠拿着提訂單來提貨,這期間能夠幹別的任何事情。其中Future 接口就是定貨單,真正處理訂單的是Executor類,它根據Future接口的要求來生產產品。java
Future接口提供方法來檢測任務是否被執行完,等待任務執行完得到結果,也能夠設置任務執行的超時時間。這個設置超時的方法就是實現Java程序執行超時的關鍵。ui
Future接口是一個泛型接口,嚴格的格式應該是Future<V>,其中V表明了Future執行的任務返回值的類型。 Future接口的方法介紹以下:線程
boolean cancel (boolean mayInterruptIfRunning) 取消任務的執行。參數指定是否當即中斷任務執行,或者等等任務結束code
boolean isCancelled () 任務是否已經取消,任務正常完成前將其取消,則返回 true對象
boolean isDone () 任務是否已經完成。須要注意的是若是任務正常終止、異常或取消,都將返回true接口
V get () throws InterruptedException, ExecutionException 等待任務執行結束,而後得到V類型的結果。InterruptedException 線程被中斷異常, ExecutionException任務執行異常,若是任務被取消,還會拋出CancellationException
get
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實現超時執行的代碼以下:it
ExecutorService executor = Executors.newSingleThreadExecutor(); FutureTask<String> future = new FutureTask<String>(new Callable<String>() {//使用Callable接口做爲構造參數 public String call() { //真正的任務在這裏執行,這裏的返回值類型爲String,能夠爲任意類型 }}); executor.execute(future); //在這裏能夠作別的任何事情 try { result = future.get(5000, TimeUnit.MILLISECONDS); //取得結果,同時設置超時執行時間爲5秒。一樣能夠用future.get(),不設置執行超時時間取得結果 } catch (InterruptedException e) { futureTask.cancel(true); } catch (ExecutionException e) { futureTask.cancel(true); } catch (TimeoutException e) { futureTask.cancel(true); } finally { executor.shutdown(); }
不直接構造Future對象,也可使用ExecutorService.submit方法來得到Future對象,submit方法即支持以 Callable接口類型,也支持Runnable接口做爲參數,具備很大的靈活性。使用示例以下:io
ExecutorService executor = Executors.newSingleThreadExecutor(); FutureTask<String> future = executor.submit( new Callable<String>() {//使用Callable接口做爲構造參數 public String call() { //真正的任務在這裏執行,這裏的返回值類型爲String,能夠爲任意類型 }}); //在這裏能夠作別的任何事情 //同上面取得結果的代碼