* Callable是類似于Runnable的接口，實現(xiàn)Callable接口的類和實現(xiàn)Runnable的類都是可被其它線程執(zhí)行的任務(wù)。

* Callable和Runnable有幾點不同：

* （1）Callable規(guī)定的方法是call()，而Runnable規(guī)定的方法是run().

* （2）Callable的任務(wù)執(zhí)行后可返回值，而Runnable的任務(wù)是不能返回值的。

* （3）call()方法可拋出異常，而run()方法是不能拋出異常的。

* （4）運行Callable任務(wù)可拿到一個Future對象，

* Future 表示異步計算的結(jié)果。它提供了檢查計算是否完成的方法，以等待計算的完成，并檢索計算的結(jié)果。

* 通過Future對象可了解任務(wù)執(zhí)行情況，可取消任務(wù)的執(zhí)行，還可獲取任務(wù)執(zhí)行的結(jié)果。

例子：

public class TimeOut { public static void main(String[] args){ int timeout = 2; //秒. ExecutorService executor = Executors.newSingleThreadExecutor(); Boolean result = false; Future<Boolean> future = executor.submit(new MyJob("請求參數(shù)=="));// 將任務(wù)提交到線程池中 try { result = future.get(timeout*10000, TimeUnit.MILLISECONDS);// 設(shè)定在200毫秒的時間內(nèi)完成 System.out.println(result); } catch (InterruptedException e) { System.out.println("線程中斷出錯。"); future.cancel(true);// 中斷執(zhí)行此任務(wù)的線程 } catch (ExecutionException e) { System.out.println("線程服務(wù)出錯。"); future.cancel(true);// 中斷執(zhí)行此任務(wù)的線程 } catch (TimeoutException e) {// 超時異常 System.out.println("超時。"); future.cancel(true);// 中斷執(zhí)行此任務(wù)的線程 }finally{ System.out.println("線程服務(wù)關(guān)閉。"); executor.shutdown(); } } static class MyJob implements Callable<Boolean> { private String t; public MyJob(String temp){ this.t= temp; } public Boolean call() { //調(diào)整i大小測試超時for(int i=0;i<999999999;i++){ if(i==2){ System.out.println(t); } if (Thread.interrupted()){ //很重要 return false; } } System.out.println("繼續(xù)執(zhí)行.........."); return true; } } } public class TimeoutTest1 {public static void main(String[] args) {final ExecutorService service = Executors.newFixedThreadPool(1);TaskThread taskThread = new TaskThread();System.out.println("提交任務(wù)...begin");Future<Object> taskFuture = service.submit(taskThread);System.out.println("提交任務(wù)...end");try {Object re = taskFuture.get(6000, TimeUnit.MILLISECONDS);// 超時設(shè)置，6sSystem.out.println(re);} catch (InterruptedException e) {e.printStackTrace();} catch (ExecutionException e) {e.printStackTrace();} catch (TimeoutException e) {System.out.println("超時 取消任務(wù)");taskFuture.cancel(true);System.out.println("超時 取消任務(wù)OK");} finally {service.shutdown();}} }class TaskThread implements Callable<Object> {public Object call() throws Exception {String result = "空結(jié)果";try {System.out.println("任務(wù)開始....");//修改sleep 的值測試超時Thread.sleep(500);result = "正確結(jié)果";System.out.println("任務(wù)結(jié)束....");} catch (Exception e) {System.out.println("Task is interrupted!");}return result;} }

?

轉(zhuǎn)載于:https://www.cnblogs.com/sprinng/p/5849710.html

總結(jié)

以上是生活随笔為你收集整理的Callable 和 Future接口 学习的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。