您好,登錄后才能下訂單哦!
本篇文章給大家分享的是有關(guān)Java中如何使用Callable和Future接口詳解,小編覺(jué)得挺實(shí)用的,因此分享給大家學(xué)習(xí),希望大家閱讀完這篇文章后可以有所收獲,話不多說(shuō),跟著小編一起來(lái)看看吧。
Runnable是一個(gè)接口,而Thread是Runnable的一個(gè)實(shí)現(xiàn)類。
所以也就有了之前創(chuàng)建線程的兩種方法
繼承Thread
實(shí)現(xiàn)Runnable
我們看一下新建線程的方法:
都是得傳入一個(gè)Runnable對(duì)象(這句話很關(guān)鍵)
所以傳入一個(gè)Runnble和Thread對(duì)象都行。
為了實(shí)現(xiàn) Runnable,需要實(shí)現(xiàn)不返回任何內(nèi)容的 run()方法,而對(duì)于
Callable,需要實(shí)現(xiàn)在完成時(shí)返回結(jié)果的 call()方法。
? call()方法可以引發(fā)異常,而 run()則不能。
Callable最大的特點(diǎn)就是 它能返回?cái)?shù)值,并拋出異常,而且它不是run()方法,而是call()方法。
但是Callable最大的問(wèn)題就是不能丟人Thread類中直接創(chuàng)建,因?yàn)門hread只認(rèn)識(shí)Runnable,所以我們必須找到Callable和Runnable之間的橋梁。
也就是找一個(gè)類,即和Runnable友關(guān)系,又和Callable有關(guān)系。
這個(gè)類就是FutureTask了。
Runnable接口有實(shí)現(xiàn)類FutureTask
FutureTask構(gòu)造可以傳遞Callable
所以創(chuàng)建也給Callable可以這樣
新類 MyThread2 實(shí)現(xiàn) callable 接口 class MyThread2 implements Callable<Integer>{ @Override public Integer call() throws Exception { return 200; }
1、新建一個(gè)callable對(duì)象
Callable callable = new MyThread2()
2、傳入callable對(duì)象,并新建一個(gè)futuretask對(duì)象,
FutureTask futureTask2 = new FutureTask(callable)
也可以之間通過(guò)lam表達(dá)式(函數(shù)式接口)實(shí)現(xiàn)
3、新建一個(gè)線程,傳入FutureTask對(duì)象
new Thread(futureTask2, “線程二”).start()
這就是基本步驟。
接下來(lái)可以來(lái)擴(kuò)展地講講 futuretask的作用
Future 接口
當(dāng) call()方法完成時(shí),結(jié)果必須存儲(chǔ)在主線程已知的對(duì)象中,以便主線程可以知道該線程返回的結(jié)果。為此,可以使用 Future 對(duì)象。
將 Future 視為保存結(jié)果的對(duì)象–它可能暫時(shí)不保存結(jié)果,但將來(lái)會(huì)保存(一旦Callable 返回)。Future 基本上是主線程可以跟蹤進(jìn)度以及其他線程的結(jié)果的一種方式。要實(shí)現(xiàn)此接口,必須重寫 5 種方法,這里列出了重要的方法,如下:
? public boolean cancel(boolean mayInterrupt):用于停止任務(wù)。
如果尚未啟動(dòng),它將停止任務(wù)。如果已啟動(dòng),則僅在 mayInterrupt 為 true時(shí)才會(huì)中斷任務(wù)。
? public Object get()拋出 InterruptedException,ExecutionException:
用于獲取任務(wù)的結(jié)果。
如果任務(wù)完成,它將立即返回結(jié)果,否則將等待任務(wù)完成,然后返回結(jié)果。
? public boolean isDone():如果任務(wù)完成,則返回 true,否則返回 false可以看到 Callable 和 Future 做兩件事-Callable 與 Runnable 類似,因?yàn)樗庋b了要在另一個(gè)線程上運(yùn)行的任務(wù),而 Future 用于存儲(chǔ)從另一個(gè)線程獲得的結(jié)
果。實(shí)際上,future 也可以與 Runnable 一起使用。
要?jiǎng)?chuàng)建線程,需要 Runnable。為了獲得結(jié)果,需要 future。
FutureTask
Java 庫(kù)具有具體的 FutureTask 類型,該類型實(shí)現(xiàn) Runnable 和 Future,并方便地將兩種功能組合在一起。 可以通過(guò)為其構(gòu)造函數(shù)提供 Callable 來(lái)創(chuàng)建FutureTask。然后,將 FutureTask 對(duì)象提供給 Thread 的構(gòu)造函數(shù)以創(chuàng)建Thread 對(duì)象。因此,間接地使用 Callable 創(chuàng)建線程。
核心原理:(重點(diǎn))
在主線程中需要執(zhí)行比較耗時(shí)的操作時(shí),但又不想阻塞主線程時(shí),可以把這些作業(yè)交給 Future 對(duì)象在后臺(tái)完成
? 當(dāng)主線程將來(lái)需要時(shí),就可以通過(guò) Future 對(duì)象獲得后臺(tái)作業(yè)的計(jì)算結(jié)果或者執(zhí)行狀態(tài)
? 一般 FutureTask 多用于耗時(shí)的計(jì)算,主線程可以在完成自己的任務(wù)后,再去獲取結(jié)果。
? 僅在計(jì)算完成時(shí)才能檢索結(jié)果;如果計(jì)算尚未完成,則阻塞 get 方法
? 一旦計(jì)算完成,就不能再重新開始或取消計(jì)算
? get 方法而獲取結(jié)果只有在計(jì)算完成時(shí)獲取,否則會(huì)一直阻塞直到任務(wù)轉(zhuǎn)入完成狀態(tài),然后會(huì)返回結(jié)果或者拋出異常
? get 只計(jì)算一次,因此 get 方法放到最后
舉個(gè)例子吧。
比如現(xiàn)在老師在上課,但是他渴了,他想買水,但是還得繼續(xù)上課。
這時(shí)就可以單獨(dú)開啟一條線程,讓班長(zhǎng)去幫他買水。(開啟單獨(dú)一條線程,不影響主線程的運(yùn)行)
get方法可以得到return的值
isDone()方法可以判斷是否完成了。
以上就是Java中如何使用Callable和Future接口詳解,小編相信有部分知識(shí)點(diǎn)可能是我們?nèi)粘9ぷ鲿?huì)見到或用到的。希望你能通過(guò)這篇文章學(xué)到更多知識(shí)。更多詳情敬請(qǐng)關(guān)注億速云行業(yè)資訊頻道。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。