1.接口的定義：
public interface Callable<V> { V call() throws Exception; } 2.Callable和Runnable的異同
先看下Runnable接口的定義
public interface Runnable { public abstract void run();}Callable的call()方法類似于Runnable接口中run()方法，都定義任務(wù)要完成的工作，實(shí)現(xiàn)這兩個(gè)接口時(shí)要分別重寫這兩個(gè)方法，主要的不同之處是call()方法是有返回值的（其實(shí)還有一些區(qū)別，例如call方法可以拋出異常，run方法不可以），運(yùn)行Callable任務(wù)可以拿到一個(gè)Future對(duì)象，表示異步計(jì)算的結(jié)果。它提供了檢查計(jì)算是否完成的方法，以等待計(jì)算的完成，并檢索計(jì)算的結(jié)果。通過Future對(duì)象可以了解任務(wù)執(zhí)行情況，可取消任務(wù)的執(zhí)行，還可獲取執(zhí)行結(jié)果。
3. Callable類型的任務(wù)可以有兩種執(zhí)行方式：
我們先定義一個(gè)Callable任務(wù)MyCallableTask:
class MyCallableTask implements Callable<Integer>{ @Override public Integer call() throws Exception { System.out.println("線程在進(jìn)行計(jì)算"); Thread.sleep(3000); int sum = 0; for(int i=0;i<100;i++) sum += i; return sum; }}①借助FutureTask執(zhí)行
FutureTask類同時(shí)實(shí)現(xiàn)了兩個(gè)接口，F(xiàn)uture和Runnable接口，所以它既可以作為Runnable被線程執(zhí)行，又可以作為Future得到Callable的返回值。
借助FutureTask執(zhí)行的大體流程是：
Callable<Integer> mycallabletask = new MyCallableTask(); FutureTask<Integer> futuretask= new FutureTask<Integer>(mycallabletask); new Thread(futuretask).start();
通過futuretask可以得到MyCallableTask的call()的運(yùn)行結(jié)果： futuretask.get();
②借助線程池來運(yùn)行
線程池中執(zhí)行Callable任務(wù)的原型例如：
public interface ExecutorService extends Executor { //提交一個(gè)Callable任務(wù)，返回值為一個(gè)Future類型 <T> Future<T> submit(Callable<T> task); //other methods... }借助線程池來運(yùn)行Callable任務(wù)的一般流程為：
ExecutorService exec = Executors.newCachedThreadPool(); Future<Integer> future = exec.submit(new MyCallableTask());
通過future可以得到MyCallableTask的call()的運(yùn)行結(jié)果： future.get();
在網(wǎng)上看到了幾個(gè)比較好的代碼例子：
a.Callable任務(wù)借助FutureTask運(yùn)行：
public class CallableAndFutureTask { public static void main(String[] args) { Callable<Integer> callable = new Callable<Integer>() { public Integer call() throws Exception { return new Random().nextInt(100); } }; FutureTask<Integer> future = new FutureTask<Integer>(callable); new Thread(future).start(); try { Thread.sleep(5000); System.out.println(future.get()); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } }}b.Callable任務(wù)和線程池一起使用，然后返回值是Future:
public class CallableAndFuture { public static void main(String[] args) { ExecutorService threadPool = Executors.newSingleThreadExecutor(); Future<Integer> future = threadPool.submit(new Callable<Integer>() { public Integer call() throws Exception { return new Random().nextInt(100); } }); try { Thread.sleep(5000);// 可能做一些事情 System.out.println(future.get()); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } }}c.當(dāng)執(zhí)行多個(gè)Callable任務(wù)，有多個(gè)返回值時(shí)，我們可以創(chuàng)建一個(gè)Future的集合，例如：
class MyCallableTask implements Callable<String> { private int id; public OneTask(int id){ this.id = id; } @Override public String call() throws Exception { for(int i = 0;i<5;i++){ System.out.println("Thread"+ id); Thread.sleep(1000); } return "Result of callable: "+id; } }public class Test { public static void main(String[] args) { //Callable<String> mycallabletask = new MyCallableTask(1); ExecutorService exec = Executors.newCachedThreadPool(); ArrayList<Future<String>> results = new ArrayList<Future<String>>(); for (int i = 0; i < 5; i++) { results.add(exec.submit(new MyCallableTask(i))); } for (Future<String> fs : results) { if (fs.isDone()) { try { System.out.println(fs.get()); } catch (Exception e) { e.printStackTrace(); } } else { System.out.println("MyCallableTask任務(wù)未完成！"); } } exec.shutdown(); } }那么引入Callable接口具有哪些好處呢？
①可以獲得任務(wù)執(zhí)行返回值；
②通過與Future的結(jié)合，可以實(shí)現(xiàn)利用Future來跟蹤異步計(jì)算的結(jié)果。
以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持VeVb武林網(wǎng)。
新聞熱點(diǎn)
疑難解答
圖片精選
