Java併發程式設計:Callable、Future和FutureTask
本篇說明的是Callable和Future,它倆很有意思的,一個產生結果,一個拿到結果。 Callable介面類似於Runnable,從名字就可以看出來了,但是Runnable不會返回結果,並且無法丟擲返回結果的異常,而Callable功能更強大一些,被執行緒執行後,可以返回值,這個返回值可以被Future拿到,也就是說,Future可以拿到非同步執行任務的返回值
建立執行緒的2種方式,一種是直接繼承Thread,另外一種就是實現Runnable介面。
這2種方式都有一個缺陷就是:在執行完任務之後無法獲取執行結果。
如果需要獲取執行結果,就必須通過共享變數或者使用執行緒通訊的方式來達到效果,這樣使用起來就比較麻煩。
而自從Java 1.5開始,就提供了Callable和Future,通過它們可以在任務執行完畢之後得到任務執行結果。
今天我們就來討論一下Callable、Future和FutureTask三個類的使用方法。以下是本文的目錄大綱:
一.Callable與Runnable
二.Future
三.FutureTask
一.Callable與Runnable
先說一下java.lang.Runnable吧,它是一個介面,在它裡面只聲明瞭一個run()方法:
1 2 3 |
|
由於run()方法返回值為void型別,所以在執行完任務之後無法返回任何結果。
Callable位於java.util.concurrent包下,它也是一個介面,在它裡面也只聲明瞭一個方法,只不過這個方法叫做call():
1 2 3 4 5 6 7 8 9 |
|
可以看到,這是一個泛型介面,call()函式返回的型別就是傳遞進來的V型別。
那麼怎麼使用Callable呢?一般情況下是配合ExecutorService來使用的,在ExecutorService介面中聲明瞭若干個submit方法的過載版本:
1 2 3 |
|
第一個submit方法裡面的引數型別就是Callable。
暫時只需要知道Callable一般是和ExecutorService配合來使用的,具體的使用方法講在後面講述。
一般情況下我們使用第一個submit方法和第三個submit方法,第二個submit方法很少使用。
二.Future
Future就是對於具體的Runnable或者Callable任務的執行結果進行取消、查詢是否完成、獲取結果。必要時可以通過get方法獲取執行結果,該方法會阻塞直到任務返回結果。
Future類位於java.util.concurrent包下,它是一個介面:
1 2 3 4 5 6 7 8 |
|
在Future介面中聲明瞭5個方法,下面依次解釋每個方法的作用:
- cancel方法用來取消任務,如果取消任務成功則返回true,如果取消任務失敗則返回false。引數mayInterruptIfRunning表示是否允許取消正在執行卻沒有執行完畢的任務,如果設定true,則表示可以取消正在執行過程中的任務。如果任務已經完成,則無論mayInterruptIfRunning為true還是false,此方法肯定返回false,即如果取消已經完成的任務會返回false;如果任務正在執行,若mayInterruptIfRunning設定為true,則返回true,若mayInterruptIfRunning設定為false,則返回false;如果任務還沒有執行,則無論mayInterruptIfRunning為true還是false,肯定返回true。
- isCancelled方法表示任務是否被取消成功,如果在任務正常完成前被取消成功,則返回 true。
- isDone方法表示任務是否已經完成,若任務完成,則返回true;
- get()方法用來獲取執行結果,這個方法會產生阻塞,會一直等到任務執行完畢才返回;
- get(long timeout, TimeUnit unit)用來獲取執行結果,如果在指定時間內,還沒獲取到結果,就直接返回null。
也就是說Future提供了三種功能:
1)判斷任務是否完成;
2)能夠中斷任務;
3)能夠獲取任務執行結果。
因為Future只是一個介面,所以是無法直接用來建立物件使用的,因此就有了下面的FutureTask。
三.FutureTask
我們先來看一下FutureTask的實現:
1 |
|
FutureTask類實現了RunnableFuture介面,我們看一下RunnableFuture介面的實現:
1 2 3 |
|
可以看出RunnableFuture繼承了Runnable介面和Future介面,而FutureTask實現了RunnableFuture介面。所以它既可以作為Runnable被執行緒執行,又可以作為Future得到Callable的返回值。
FutureTask提供了2個構造器:
1 2 3 4 |
|
事實上,FutureTask是Future介面的一個唯一實現類。
四.使用示例
1.使用Callable+Future獲取執行結果
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 |
|
執行結果:
子執行緒在進行計算 主執行緒在執行任務 task執行結果4950 所有任務執行完畢
2.使用Callable+FutureTask獲取執行結果
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 |
|
如果為了可取消性而使用 Future 但又不提供可用的結果,則可以宣告 Future<?> 形式型別、並返回 null 作為底層任務的結果。
原文連結:
參考連結: