剛把Thread 的知識(shí)理了一遍。

Runnable是一個(gè)接口，而Thread是Runnable的一個(gè)實(shí)現(xiàn)類。

所以也就有了之前創(chuàng)建線程的兩種方法

• 繼承Thread
• 實(shí)現(xiàn)Runnable

我們看一下新建線程的方法：

都是得傳入一個(gè)Runnable對(duì)象（這句話很關(guān)鍵）

所以傳入一個(gè)Runnble和Thread對(duì)象都行。

現(xiàn)在引入創(chuàng)建線程的第三種方法：Callable

為了實(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最大的問題就是不能丟人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)

也可以之間通過lam表達(dá)式（函數(shù)式接口）實(shí)現(xiàn)

3、新建一個(gè)線程，傳入FutureTask對(duì)象

new Thread(futureTask2, “線程二”).start()

這就是基本步驟。

接下來可以來擴(kuò)展地講講 futuretask的作用

Future對(duì)象

Future 接口

當(dāng) call（）方法完成時(shí)，結(jié)果必須存儲(chǔ)在主線程已知的對(duì)象中，以便主線程可以知道該線程返回的結(jié)果。為此，可以使用 Future 對(duì)象。

將 Future 視為保存結(jié)果的對(duì)象–它可能暫時(shí)不保存結(jié)果，但將來會(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 庫具有具體的 FutureTask 類型，該類型實(shí)現(xiàn) Runnable 和 Future，并方便地將兩種功能組合在一起。 可以通過為其構(gòu)造函數(shù)提供 Callable 來創(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)主線程將來需要時(shí)，就可以通過 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（）方法可以判斷是否完成了。

第一次會(huì)計(jì)算，第二次（之前計(jì)算過的），就直接返回結(jié)果了。

總結(jié)

到此這篇關(guān)于Java并發(fā)教程之Callable和Future接口的文章就介紹到這了,更多相關(guān)Java并發(fā)Callable和Future接口內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論