日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 编程问答 >内容正文

编程问答

Callable类

發布時間:2023/12/20 编程问答 29 豆豆
生活随笔 收集整理的這篇文章主要介紹了 Callable类 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
(一)
Callable和Runnable比較相似,都可以用來實現線程任務。但callable使用了泛型設計,使用一個V類型值,能夠
在執行結束后返回一個V類型的值。而Runable只會返回一個void,不能夠獲得執行的結果。

(二)
使用Callable要和Future類或者Futuretask類搭配使用,他們類似一種對線程執行任務的返回數據的操作的封裝類。
使用方法
1 Callable 和 future
首先寫一個Callable接口的實例,實現Call()方法,然后通過Thread或者線程池submit函數使用這個Callable實例,

將返回結果賦值給future類型的一個實例,然后就可以通過這個實例對返回的結果進行get查詢等操作

public class Test {public static void main(String[] args) {ExecutorService executor = Executors.newCachedThreadPool();Task task = new Task();Future<Integer> result = executor.submit(task);executor.shutdown();try {Thread.sleep(1000);} catch (InterruptedException e1) {e1.printStackTrace();}System.out.println("主線程在執行任務");try {System.out.println("task運行結果"+result.get());} catch (InterruptedException e) {e.printStackTrace();} catch (ExecutionException e) {e.printStackTrace();}System.out.println("所有任務執行完畢");} } class Task implements Callable<Integer>{@Overridepublic Integer call() throws Exception {System.out.println("子線程在進行計算");Thread.sleep(3000);int sum = 0;for(int i=0;i<100;i++)sum += i;return sum;} }


2 Callable 和 futuretask
futuretask不同于future,它進一步豐富了future的功能。futuretask實現了Runnalefuture接口,這是他具有了可以
被線程執行的能力。所以使用時直接可以把實例化好的Callable實例以參數的形式傳給它,然后就可以直接使用Thread
或者線程池submit函數操作它。在最后直接調用它的get函數就能獲得相應的返回結果,當然他還有很多其他的功能。

public class Test {public static void main(String[] args) {//第一種方式ExecutorService executor = Executors.newCachedThreadPool();Task task = new Task();FutureTask<Integer> futureTask = new FutureTask<Integer>(task);executor.submit(futureTask);executor.shutdown();//第二種方式,注意這種方式和第一種方式效果是類似的,只不過一個使用的是ExecutorService,一個使用的是Thread/*Task task = new Task();FutureTask<Integer> futureTask = new FutureTask<Integer>(task);Thread thread = new Thread(futureTask);thread.start();*/try {Thread.sleep(1000);} catch (InterruptedException e1) {e1.printStackTrace();}System.out.println("主線程在執行任務");try {System.out.println("task運行結果"+futureTask.get());} catch (InterruptedException e) {e.printStackTrace();} catch (ExecutionException e) {e.printStackTrace();}System.out.println("所有任務執行完畢");} } class Task implements Callable<Integer>{@Overridepublic Integer call() throws Exception {System.out.println("子線程在進行計算");Thread.sleep(3000);int sum = 0;for(int i=0;i<100;i++)sum += i;return sum;} }


總結

以上是生活随笔為你收集整理的Callable类的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。