什么是Future焚碌?干什么的解決什么問題?在什么情況使用霸妹?
帶著問題十电,我們?nèi)タ纯础?/p>
首先,F(xiàn)uture對象是一個異步計算的結(jié)果叹螟,而在Callable任務(wù)中可以拿到這個Future的對象鹃骂。那同樣是run執(zhí)行,為什么Runable沒有這個對象?
? ? ? ? ?這還是一個設(shè)計思路的問題罢绽,google希望我們執(zhí)行一個普通的任務(wù)的時候畏线,大家都去用Runable就好了,執(zhí)行完系統(tǒng)就幫你銷毀了良价,而當(dāng)我們需要得到一個Future的時候寝殴,意味著我們的使用場景不同了,我們需要他來幫我們分析任務(wù)在執(zhí)行過程中出現(xiàn)了哪些狀況明垢。
也就是說Runable沒必要有返回值蚣常,因為我已經(jīng)有一個更適合的角色Future幫我去做這件事了,設(shè)計就是如此痊银。
Future這個接口
interface Future<V> ?泛型未知抵蚊,需要我們傳遞一個指定的類型
看一下源碼的注釋
* @see FutureTask
?* @see Executor
?* @since 1.5?
* @author Doug Lea?
* @paramThe result type returned by this Future's {@code get} method
1.see 提示我們參考FutureTask 和 Executor
2.實現(xiàn)版本java1.5版本
3.分享者Doug Lea,對Java影響力最大的個人曼验,util.concurrent包的來源
我們可以瞻仰一下Doug Lea作者泌射,希望能早日?達到 ?接近大神
再來看看concurrent包下的內(nèi)容,難以想象人家的大腦到底裝了些什么,沒有對比就沒有傷害鬓照。
Future接口方法
boolean cancel(boolean mayInterruptIfRunning);
mayInterruptIfRunning參數(shù)的字面含義是“可能中斷運行”熔酷,他有很多情況,為什么會有這么多種情況還要參見FutureTask中的定義
1.如果任務(wù)已經(jīng)執(zhí)行完畢豺裆,那么返回false拒秘。
2.如果任務(wù)已經(jīng)取消,那么返回false臭猜。
3.如果任務(wù)已經(jīng)停止躺酒,則cancel()方法會返回true。
4.mayInterruptIfRunning是否中斷其運行蔑歌,設(shè)置ture中斷羹应,否者任務(wù)將繼續(xù)運行直到結(jié)束。
5.此方法返回后任務(wù)要么處于運行結(jié)束狀態(tài)次屠,要么處于取消狀態(tài)园匹。isDone()將永遠(yuǎn)返回true雳刺,如果cancel()方法返回true,isCancelled()始終返回true裸违。
boolean isCancelled();
是否被取消掖桦,如果計算在正常結(jié)束前被取消了,則返回true
boolean isDone();?
是否完成
V get() throws InterruptedException, ExecutionException;
返回結(jié)果供汛,如果計算未完成枪汪,則等待任務(wù)完成,計算被取消拋的異常和執(zhí)行時異常
V get(long timeout, TimeUnit unit)
throws InterruptedException, ExecutionException, TimeoutException;
設(shè)置一個等待時間怔昨,超時會拋異常雀久,比上面的方法多出一個超時的異常。
總結(jié)一下就是:Future就是對Callable任務(wù)的執(zhí)行結(jié)果進行取消趁舀、查詢是否完成岸啡、獲取結(jié)果、設(shè)置結(jié)果操作赫编。get方法會阻塞,直到任務(wù)返回結(jié)果()為止奋隶。
FutureTask
Future主要通過FutureTask結(jié)合線程池來使用擂送。FutureTask實現(xiàn)了RunnableFuture接口(1.6版本出現(xiàn)),而RunnableFuture又同時實現(xiàn)了Runnable和Future<V>接口唯欣,意味著可以交給Executor執(zhí)行嘹吨,這里很有趣的是,既然RunnableFuture是1.6才出來境氢,換言之在1.5出現(xiàn)線程池的時候調(diào)用方式只能在FutureTask中通過.run()來運行蟀拷。
我們先看看FutureTask中構(gòu)造方法。
publicFutureTask(Runnable runnable,Vresult) {
this.callable= Executors.callable(runnable, result);
this.state=NEW;// ensure visibility of callable
}
初始化狀態(tài)為NEW萍聊,下面是狀態(tài)的設(shè)置0-6问芬。
private volatile int state;
private static final int NEW? ? ? ? ? = 0;
private static final int COMPLETING? = 1;
private static final int NORMAL? ? ? = 2;
private static final int EXCEPTIONAL? = 3;
private static final int CANCELLED? ? = 4;
private static final int INTERRUPTING = 5;
private static final int INTERRUPTED? = 6;
run() 方法中執(zhí)行成功調(diào)用set(狀態(tài)),執(zhí)行失敗拋異常寿桨,如下此衅。
if(c !=null&&state==NEW) {
Vresult;
booleanran;
try{
result = c.call();
ran =true;
}catch(Throwable ex) {
result =null;
ran =false;
setException(ex);
}
if (ran)
set(result);
set方法中把狀態(tài)設(shè)置成COMPLETING 然后設(shè)置成NORMAL,換言之run()執(zhí)行完畢狀態(tài)都會改變亭螟,不再為NEW了挡鞍,如下。
protected void set(Vv) {
if(UNSAFE.compareAndSwapInt(this,stateOffset,NEW,COMPLETING)) {
outcome= v;
UNSAFE.putOrderedInt(this,stateOffset,NORMAL);// final state
finishCompletion();
}
}
接著是cancel()方法中設(shè)為ture時把狀態(tài) NEW->INTERRUPTING ->INTERRUPTED预烙,cancel()為false的狀態(tài)變化就是NEW->=CANCELLED墨微。
cancel()方法僅僅只是改變了futureTask的狀態(tài)位并沒有起到結(jié)束進程的作用,這是為什么呢扁掸?
我們看看future.get()方法可知翘县,如果一個futureTask被cancel()了最域,調(diào)用get()方法會拋出CancellationException。也就是說cancel(true)方法也只是希望當(dāng)前線程可以響應(yīng)中斷而已炼蹦,當(dāng)線程被阻塞羡宙,拋出InterruptedException。也就可以解釋的通為什么future的方法
boolean cancel(boolean mayInterruptIfRunning)? 中定義為什么取名為mayInterruptIfRunning了掐隐。