Java並發教程之Callable和Future接口詳解

Posted on by

剛把Thread 的知識理瞭一遍。

Runnable是一個接口，而Thread是Runnable的一個實現類。

所以也就有瞭之前創建線程的兩種方法

  • 繼承Thread
  • 實現Runnable

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

都是得傳入一個Runnable對象（這句話很關鍵）

所以傳入一個Runnble和Thread對象都行。

現在引入創建線程的第三種方法：Callable

為瞭實現 Runnable，需要實現不返回任何內容的 run（）方法，而對於

Callable，需要實現在完成時返回結果的 call（）方法。

• call（）方法可以引發異常，而 run（）則不能。

Callable最大的特點就是 它能返回數值，並拋出異常，而且它不是run（）方法，而是call（）方法。

但是Callable最大的問題就是不能丟人Thread類中直接創建，因為Thread隻認識Runnable，所以我們必須找到Callable和Runnable之間的橋梁。

也就是找一個類，即和Runnable友關系，又和Callable有關系。

這個類就是FutureTask瞭。

  • Runnable接口有實現類FutureTask
  • FutureTask構造可以傳遞Callable

所以創建也給Callable可以這樣

新類 MyThread2 實現 callable 接口
class MyThread2 implements Callable<Integer>{
@Override
public Integer call() throws Exception {
return 200;
}

1、新建一個callable對象

Callable callable = new MyThread2()

2、傳入callable對象，並新建一個futuretask對象，

FutureTask futureTask2 = new FutureTask(callable)

也可以之間通過lam表達式（函數式接口）實現

3、新建一個線程，傳入FutureTask對象

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

這就是基本步驟。

接下來可以來擴展地講講 futuretask的作用

Future對象

Future 接口

當 call（）方法完成時，結果必須存儲在主線程已知的對象中，以便主線程可以知道該線程返回的結果。為此，可以使用 Future 對象。

將 Future 視為保存結果的對象–它可能暫時不保存結果，但將來會保存（一旦Callable 返回）。Future 基本上是主線程可以跟蹤進度以及其他線程的結果的一種方式。要實現此接口，必須重寫 5 種方法，這裡列出瞭重要的方法,如下:

• public boolean cancel（boolean mayInterrupt）：用於停止任務。

如果尚未啟動，它將停止任務。如果已啟動，則僅在 mayInterrupt 為 true時才會中斷任務。

• public Object get（）拋出 InterruptedException，ExecutionException：

用於獲取任務的結果。

如果任務完成，它將立即返回結果，否則將等待任務完成，然後返回結果。

• public boolean isDone（）：如果任務完成，則返回 true，否則返回 false可以看到 Callable 和 Future 做兩件事-Callable 與 Runnable 類似，因為它封裝瞭要在另一個線程上運行的任務，而 Future 用於存儲從另一個線程獲得的結
果。實際上，future 也可以與 Runnable 一起使用。

要創建線程，需要 Runnable。為瞭獲得結果，需要 future。

FutureTask

Java 庫具有具體的 FutureTask 類型，該類型實現 Runnable 和 Future，並方便地將兩種功能組合在一起。 可以通過為其構造函數提供 Callable 來創建FutureTask。然後，將 FutureTask 對象提供給 Thread 的構造函數以創建Thread 對象。因此，間接地使用 Callable 創建線程。

核心原理:(重點)

在主線程中需要執行比較耗時的操作時，但又不想阻塞主線程時，可以把這些作業交給 Future 對象在後臺完成

• 當主線程將來需要時，就可以通過 Future 對象獲得後臺作業的計算結果或者執行狀態

• 一般 FutureTask 多用於耗時的計算，主線程可以在完成自己的任務後，再去獲取結果。

• 僅在計算完成時才能檢索結果；如果計算尚未完成，則阻塞 get 方法

• 一旦計算完成，就不能再重新開始或取消計算

• get 方法而獲取結果隻有在計算完成時獲取，否則會一直阻塞直到任務轉入完成狀態，然後會返回結果或者拋出異常

• get 隻計算一次,因此 get 方法放到最後

舉個例子吧。

比如現在老師在上課，但是他渴瞭，他想買水，但是還得繼續上課。

這時就可以單獨開啟一條線程，讓班長去幫他買水。（開啟單獨一條線程，不影響主線程的運行）

get方法可以得到return的值

isDone（）方法可以判斷是否完成瞭。


第一次會計算，第二次（之前計算過的），就直接返回結果瞭。

總結

到此這篇關於Java並發教程之Callable和Future接口的文章就介紹到這瞭,更多相關Java並發Callable和Future接口內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet！

推薦閱讀：