Java-Future學(xué)習(xí)

什么是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作者泌射,希望能早日?達到 ?接近大神


紐約州立大學(xué)Oswego分校計算機科學(xué)系的老大爺


再來看看concurrent包下的內(nèi)容,難以想象人家的大腦到底裝了些什么,沒有對比就沒有傷害鬓照。


大量有關(guān)線程池和隊列的類


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了掐隐。

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末狗热,一起剝皮案震驚了整個濱河市,隨后出現(xiàn)的幾起案子虑省,更是在濱河造成了極大的恐慌匿刮,老刑警劉巖,帶你破解...
    沈念sama閱讀 206,126評論 6 481
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件探颈,死亡現(xiàn)場離奇詭異熟丸,居然都是意外死亡,警方通過查閱死者的電腦和手機伪节,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 88,254評論 2 382
  • 文/潘曉璐 我一進店門光羞,熙熙樓的掌柜王于貴愁眉苦臉地迎上來,“玉大人怀大,你說我怎么就攤上這事纱兑。” “怎么了化借?”我有些...
    開封第一講書人閱讀 152,445評論 0 341
  • 文/不壞的土叔 我叫張陵潜慎,是天一觀的道長。 經(jīng)常有香客問我蓖康,道長铐炫,這世上最難降的妖魔是什么? 我笑而不...
    開封第一講書人閱讀 55,185評論 1 278
  • 正文 為了忘掉前任蒜焊,我火速辦了婚禮倒信,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘泳梆。我一直安慰自己堤结,他們只是感情好,可當(dāng)我...
    茶點故事閱讀 64,178評論 5 371
  • 文/花漫 我一把揭開白布鸭丛。 她就那樣靜靜地躺著竞穷,像睡著了一般。 火紅的嫁衣襯著肌膚如雪鳞溉。 梳的紋絲不亂的頭發(fā)上瘾带,一...
    開封第一講書人閱讀 48,970評論 1 284
  • 那天,我揣著相機與錄音熟菲,去河邊找鬼看政。 笑死朴恳,一個胖子當(dāng)著我的面吹牛,可吹牛的內(nèi)容都是我干的允蚣。 我是一名探鬼主播于颖,決...
    沈念sama閱讀 38,276評論 3 399
  • 文/蒼蘭香墨 我猛地睜開眼,長吁一口氣:“原來是場噩夢啊……” “哼嚷兔!你這毒婦竟也來了森渐?” 一聲冷哼從身側(cè)響起,我...
    開封第一講書人閱讀 36,927評論 0 259
  • 序言:老撾萬榮一對情侶失蹤冒晰,失蹤者是張志新(化名)和其女友劉穎同衣,沒想到半個月后,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體壶运,經(jīng)...
    沈念sama閱讀 43,400評論 1 300
  • 正文 獨居荒郊野嶺守林人離奇死亡耐齐,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 35,883評論 2 323
  • 正文 我和宋清朗相戀三年,在試婚紗的時候發(fā)現(xiàn)自己被綠了蒋情。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片埠况。...
    茶點故事閱讀 37,997評論 1 333
  • 序言:一個原本活蹦亂跳的男人離奇死亡,死狀恐怖棵癣,靈堂內(nèi)的尸體忽然破棺而出询枚,到底是詐尸還是另有隱情,我是刑警寧澤浙巫,帶...
    沈念sama閱讀 33,646評論 4 322
  • 正文 年R本政府宣布,位于F島的核電站刷后,受9級特大地震影響的畴,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜尝胆,卻給世界環(huán)境...
    茶點故事閱讀 39,213評論 3 307
  • 文/蒙蒙 一丧裁、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧含衔,春花似錦煎娇、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,204評論 0 19
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至杭隙,卻和暖如春哟绊,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背痰憎。 一陣腳步聲響...
    開封第一講書人閱讀 31,423評論 1 260
  • 我被黑心中介騙來泰國打工票髓, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留攀涵,地道東北人。 一個月前我還...
    沈念sama閱讀 45,423評論 2 352
  • 正文 我出身青樓洽沟,卻偏偏與公主長得像以故,于是被迫代替她去往敵國和親。 傳聞我的和親對象是個殘疾皇子裆操,可洞房花燭夜當(dāng)晚...
    茶點故事閱讀 42,722評論 2 345

推薦閱讀更多精彩內(nèi)容

  • Android Handler機制系列文章整體內(nèi)容如下: Android Handler機制1之ThreadAnd...
    隔壁老李頭閱讀 4,245評論 2 12
  • 一.線程安全性 線程安全是建立在對于對象狀態(tài)訪問操作進行管理跷车,特別是對共享的與可變的狀態(tài)的訪問 解釋下上面的話: ...
    黃大大吃不胖閱讀 828評論 0 3
  • Spring Cloud為開發(fā)人員提供了快速構(gòu)建分布式系統(tǒng)中一些常見模式的工具(例如配置管理棘利,服務(wù)發(fā)現(xiàn),斷路器朽缴,智...
    卡卡羅2017閱讀 134,599評論 18 139
  • 1. Java基礎(chǔ)部分 基礎(chǔ)部分的順序:基本語法善玫,類相關(guān)的語法,內(nèi)部類的語法密强,繼承相關(guān)的語法茅郎,異常的語法,線程的語...
    子非魚_t_閱讀 31,581評論 18 399
  • 近來煥跟換了個人是似的或渤,做作業(yè)拖拉系冗,書寫不端正,跟你對著干薪鹦,我們說什么都是錯的掌敬,一不順心就翻臉……不知該怎...
    晴冰閱讀 227評論 0 0