Java并發(fā)教程之Callable和Future接口詳解
剛把Thread 的知識理了一遍。
Runnable是一個接口,而Thread是Runnable的一個實現(xiàn)類。
所以也就有了之前創(chuàng)建線程的兩種方法
繼承Thread 實現(xiàn)Runnable我們看一下新建線程的方法:
都是得傳入一個Runnable對象(這句話很關(guān)鍵)
所以傳入一個Runnble和Thread對象都行。
現(xiàn)在引入創(chuàng)建線程的第三種方法:Callable為了實現(xiàn) Runnable,需要實現(xiàn)不返回任何內(nèi)容的 run()方法,而對于
Callable,需要實現(xiàn)在完成時返回結(jié)果的 call()方法。
• call()方法可以引發(fā)異常,而 run()則不能。
Callable最大的特點就是 它能返回數(shù)值,并拋出異常,而且它不是run()方法,而是call()方法。
但是Callable最大的問題就是不能丟人Thread類中直接創(chuàng)建,因為Thread只認(rèn)識Runnable,所以我們必須找到Callable和Runnable之間的橋梁。
也就是找一個類,即和Runnable友關(guān)系,又和Callable有關(guān)系。
這個類就是FutureTask了。
Runnable接口有實現(xiàn)類FutureTask FutureTask構(gòu)造可以傳遞Callable所以創(chuàng)建也給Callable可以這樣
新類 MyThread2 實現(xiàn) callable 接口class MyThread2 implements Callable<Integer>{@Overridepublic Integer call() throws Exception {return 200;}
1、新建一個callable對象
Callable callable = new MyThread2()
2、傳入callable對象,并新建一個futuretask對象,
FutureTask futureTask2 = new FutureTask(callable)
也可以之間通過lam表達(dá)式(函數(shù)式接口)實現(xiàn)
3、新建一個線程,傳入FutureTask對象
new Thread(futureTask2, “線程二”).start()
這就是基本步驟。
接下來可以來擴展地講講 futuretask的作用
Future對象Future 接口
當(dāng) call()方法完成時,結(jié)果必須存儲在主線程已知的對象中,以便主線程可以知道該線程返回的結(jié)果。為此,可以使用 Future 對象。
將 Future 視為保存結(jié)果的對象?它可能暫時不保存結(jié)果,但將來會保存(一旦Callable 返回)。Future 基本上是主線程可以跟蹤進(jìn)度以及其他線程的結(jié)果的一種方式。要實現(xiàn)此接口,必須重寫 5 種方法,這里列出了重要的方法,如下:
• public boolean cancel(boolean mayInterrupt):用于停止任務(wù)。
如果尚未啟動,它將停止任務(wù)。如果已啟動,則僅在 mayInterrupt 為 true時才會中斷任務(wù)。
• public Object get()拋出 InterruptedException,ExecutionException:
用于獲取任務(wù)的結(jié)果。
如果任務(wù)完成,它將立即返回結(jié)果,否則將等待任務(wù)完成,然后返回結(jié)果。
• public boolean isDone():如果任務(wù)完成,則返回 true,否則返回 false可以看到 Callable 和 Future 做兩件事-Callable 與 Runnable 類似,因為它封裝了要在另一個線程上運行的任務(wù),而 Future 用于存儲從另一個線程獲得的結(jié)果。實際上,future 也可以與 Runnable 一起使用。
要創(chuàng)建線程,需要 Runnable。為了獲得結(jié)果,需要 future。
FutureTask
Java 庫具有具體的 FutureTask 類型,該類型實現(xiàn) Runnable 和 Future,并方便地將兩種功能組合在一起。 可以通過為其構(gòu)造函數(shù)提供 Callable 來創(chuàng)建FutureTask。然后,將 FutureTask 對象提供給 Thread 的構(gòu)造函數(shù)以創(chuàng)建Thread 對象。因此,間接地使用 Callable 創(chuàng)建線程。
核心原理:(重點)
在主線程中需要執(zhí)行比較耗時的操作時,但又不想阻塞主線程時,可以把這些作業(yè)交給 Future 對象在后臺完成
• 當(dāng)主線程將來需要時,就可以通過 Future 對象獲得后臺作業(yè)的計算結(jié)果或者執(zhí)行狀態(tài)
• 一般 FutureTask 多用于耗時的計算,主線程可以在完成自己的任務(wù)后,再去獲取結(jié)果。
• 僅在計算完成時才能檢索結(jié)果;如果計算尚未完成,則阻塞 get 方法
• 一旦計算完成,就不能再重新開始或取消計算
• get 方法而獲取結(jié)果只有在計算完成時獲取,否則會一直阻塞直到任務(wù)轉(zhuǎn)入完成狀態(tài),然后會返回結(jié)果或者拋出異常
• get 只計算一次,因此 get 方法放到最后
舉個例子吧。
比如現(xiàn)在老師在上課,但是他渴了,他想買水,但是還得繼續(xù)上課。
這時就可以單獨開啟一條線程,讓班長去幫他買水。(開啟單獨一條線程,不影響主線程的運行)
get方法可以得到return的值
isDone()方法可以判斷是否完成了。
第一次會計算,第二次(之前計算過的),就直接返回結(jié)果了。
總結(jié)到此這篇關(guān)于Java并發(fā)教程之Callable和Future接口的文章就介紹到這了,更多相關(guān)Java并發(fā)Callable和Future接口內(nèi)容請搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持好吧啦網(wǎng)!
相關(guān)文章:
