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

* Callable和Runnable有幾點(diǎn)不同：

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

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

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

* （4）運(yùn)行Callable任務(wù)可拿到一個(gè)Future對(duì)象，

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

* 通過(guò)Future對(duì)象可了解任務(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("請(qǐng)求參數(shù)=="));// 將任務(wù)提交到線程池中 try { result = future.get(timeout*10000, TimeUnit.MILLISECONDS);// 設(shè)定在200毫秒的時(shí)間內(nèi)完成 System.out.println(result); } catch (InterruptedException e) { System.out.println("線程中斷出錯(cuò)。"); future.cancel(true);// 中斷執(zhí)行此任務(wù)的線程 } catch (ExecutionException e) { System.out.println("線程服務(wù)出錯(cuò)。"); future.cancel(true);// 中斷執(zhí)行此任務(wù)的線程 } catch (TimeoutException e) {// 超時(shí)異常 System.out.println("超時(shí)。"); 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大小測(cè)試超時(shí)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í)設(shè)置，6sSystem.out.println(re);} catch (InterruptedException e) {e.printStackTrace();} catch (ExecutionException e) {e.printStackTrace();} catch (TimeoutException e) {System.out.println("超時(shí) 取消任務(wù)");taskFuture.cancel(true);System.out.println("超時(shí) 取消任務(wù)OK");} finally {service.shutdown();}} }class TaskThread implements Callable<Object> {public Object call() throws Exception {String result = "空結(jié)果";try {System.out.println("任務(wù)開(kāi)始....");//修改sleep 的值測(cè)試超時(shí)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接口 学习的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

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