溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶服務(wù)條款》

Java中如何使用Callable和Future接口詳解

發(fā)布時(shí)間:2021-07-28 11:23:48 來(lái)源:億速云 閱讀:169 作者:Leah 欄目:開發(fā)技術(shù)

本篇文章給大家分享的是有關(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

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

Java中如何使用Callable和Future接口詳解

都是得傳入一個(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最大的問(wèn)題就是不能丟人Thread類中直接創(chuàng)建,因?yàn)門hread只認(rèn)識(shí)Runnable,所以我們必須找到Callable和Runnable之間的橋梁。

Java中如何使用Callable和Future接口詳解

也就是找一個(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)

Java中如何使用Callable和Future接口詳解

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

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

這就是基本步驟。

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

Future對(duì)象

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)行)

Java中如何使用Callable和Future接口詳解

Java中如何使用Callable和Future接口詳解

get方法可以得到return的值

Java中如何使用Callable和Future接口詳解

isDone()方法可以判斷是否完成了。

Java中如何使用Callable和Future接口詳解
Java中如何使用Callable和Future接口詳解

以上就是Java中如何使用Callable和Future接口詳解,小編相信有部分知識(shí)點(diǎn)可能是我們?nèi)粘9ぷ鲿?huì)見到或用到的。希望你能通過(guò)這篇文章學(xué)到更多知識(shí)。更多詳情敬請(qǐng)關(guān)注億速云行業(yè)資訊頻道。

向AI問(wèn)一下細(xì)節(jié)

免責(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)容。

AI