今天就跟大家聊聊有關(guān)怎么在Java中利用多線程實現(xiàn)一個Callable接口,可能很多人都不太了解,為了讓大家更加了解,小編給大家總結(jié)了以下內(nèi)容,希望大家根據(jù)這篇文章可以有所收獲。
成都創(chuàng)新互聯(lián)公司是一家集成都網(wǎng)站建設(shè)、成都網(wǎng)站制作、網(wǎng)站頁面設(shè)計、網(wǎng)站優(yōu)化SEO優(yōu)化為一體的專業(yè)的建站公司,已為成都等多地近百家企業(yè)提供網(wǎng)站建設(shè)服務(wù)。追求良好的瀏覽體驗,以探求精品塑造與理念升華,設(shè)計最適合用戶的網(wǎng)站頁面。 合作只是第一步,服務(wù)才是根本,我們始終堅持講誠信,負(fù)責(zé)任的原則,為您進(jìn)行細(xì)心、貼心、認(rèn)真的服務(wù),與眾多客戶在蓬勃發(fā)展的市場環(huán)境中,互促共生。
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ù)要完成的工作,實現(xiàn)這兩個接口時要分別重寫這兩個方法,主要的不同之處是call()方法是有返回值的(其實還有一些區(qū)別,例如call方法可以拋出異常,run方法不可以),運行Callable任務(wù)可以拿到一個Future對象,表示異步計算的結(jié)果。它提供了檢查計算是否完成的方法,以等待計算的完成,并檢索計算的結(jié)果。通過Future對象可以了解任務(wù)執(zhí)行情況,可取消任務(wù)的執(zhí)行,還可獲取執(zhí)行結(jié)果。
3. Callable類型的任務(wù)可以有兩種執(zhí)行方式:
我們先定義一個Callable任務(wù)MyCallableTask:
class MyCallableTask implements Callable<Integer>{ @Override public Integer call() throws Exception { System.out.println("線程在進(jìn)行計算"); Thread.sleep(3000); int sum = 0; for(int i=0;i<100;i++) sum += i; return sum; } }
①借助FutureTask執(zhí)行
FutureTask類同時實現(xiàn)了兩個接口,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()的運行結(jié)果: futuretask.get();
②借助線程池來運行
線程池中執(zhí)行Callable任務(wù)的原型例如:
public interface ExecutorService extends Executor { //提交一個Callable任務(wù),返回值為一個Future類型 <T> Future<T> submit(Callable<T> task); //other methods... }
借助線程池來運行Callable任務(wù)的一般流程為:
ExecutorService exec = Executors.newCachedThreadPool(); Future<Integer> future = exec.submit(new MyCallableTask());
通過future可以得到MyCallableTask的call()的運行結(jié)果: future.get();
在網(wǎng)上看到了幾個比較好的代碼例子:
a.Callable任務(wù)借助FutureTask運行:
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í)行多個Callable任務(wù),有多個返回值時,我們可以創(chuàng)建一個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é)合,可以實現(xiàn)利用Future來跟蹤異步計算的結(jié)果。
看完上述內(nèi)容,你們對怎么在Java中利用多線程實現(xiàn)一個Callable接口有進(jìn)一步的了解嗎?如果還想了解更多知識或者相關(guān)內(nèi)容,請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道,感謝大家的支持。
新聞名稱:怎么在Java中利用多線程實現(xiàn)一個Callable接口
本文URL:http://bm7419.com/article24/pcecje.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供品牌網(wǎng)站建設(shè)、搜索引擎優(yōu)化、建站公司、網(wǎng)站設(shè)計、小程序開發(fā)、虛擬主機
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)