FutureTask源碼走讀

FutureTask類圖

從類圖可以看出FutureTask簡介實現(xiàn)了Runnable赔癌、Future接口气嫁,我們知道Future用于表示異步計算的結(jié)果类茂,所以通過它我們可以獲得線程的執(zhí)行結(jié)果母市。如何獲得線程的執(zhí)行結(jié)果呢矾兜?

FutureTask獲取執(zhí)行結(jié)果

一般我們按照下面的方式使用FutureTask

//1. 創(chuàng)建FutureTask
FutureTask futureTask = new FutureTask(new CallableTest());
//2. 啟動線程
new Thread(futureTask).start();
//3 獲取線程執(zhí)行結(jié)果
String result = (String) futureTask.get();

源碼走讀

//創(chuàng)建FutureTask對象
public FutureTask(Callable<V> callable) {
if (callable == null)
    throw new NullPointerException();
this.callable = callable;
this.state = NEW;       // ensure visibility of callable
}

//調(diào)用run方法,執(zhí)行我們的業(yè)務(wù)邏輯
public void run() {
    if (state != NEW ||
        !UNSAFE.compareAndSwapObject(this, runnerOffset,
                                     null, Thread.currentThread()))
        return;
    try {
        Callable<V> c = callable;
        if (c != null && state == NEW) {
            V result;
            boolean ran;
            try {
                //我們重寫的call的方法的執(zhí)行
                result = c.call();
                ran = true;
            } catch (Throwable ex) {
                result = null;
                ran = false;
                setException(ex);
            }
            if (ran)//call方法執(zhí)行完成執(zhí)行喚醒操作
                set(result);
        }
    } finally {
        runner = null;
        int s = state;
        if (s >= INTERRUPTING)
            handlePossibleCancellationInterrupt(s);
    }
}

//執(zhí)行call方法的時候窒篱,我們主線程接著執(zhí)行g(shù)et()方法
public V get() throws InterruptedException, ExecutionException {
    int s = state;
    if (s <= COMPLETING)
        //阻塞主方法的邏輯
        s = awaitDone(false, 0L);
    return report(s);
}

//未被喚醒會一直等待直到超時或知道被中斷
private int awaitDone(boolean timed, long nanos)
    throws InterruptedException {
    final long deadline = timed ? System.nanoTime() + nanos : 0L;
    //等待隊列
    WaitNode q = null;
    boolean queued = false;
    for (;;) {
        if (Thread.interrupted()) {
            removeWaiter(q);
            throw new InterruptedException();
        }
        int s = state;
        if (s > COMPLETING) {
            if (q != null)
                q.thread = null;
            return s;
        }
        else if (s == COMPLETING) // cannot time out yet
            Thread.yield();
        else if (q == null)
            q = new WaitNode();
        else if (!queued)
            queued = UNSAFE.compareAndSwapObject(this, waitersOffset,
                                                 q.next = waiters, q);
        else if (timed) {
            nanos = deadline - System.nanoTime();
            if (nanos <= 0L) {
                removeWaiter(q);
                return state;
            }
            //阻塞操作(有超時時間)
            LockSupport.parkNanos(this, nanos);
        }
        else
            //阻塞操作
            LockSupport.park(this);
    }
}

//run()中的喚醒操作
protected void set(V v) {
    if (UNSAFE.compareAndSwapInt(this, stateOffset, NEW, COMPLETING)) {
        //執(zhí)行后結(jié)果賦值給outcome
        outcome = v;
        UNSAFE.putOrderedInt(this, stateOffset, NORMAL); // final state
        finishCompletion();
    }
}

//依次喚醒阻塞的線程
private void finishCompletion() {
        // assert state > COMPLETING;
        for (WaitNode q; (q = waiters) != null;) {
            if (UNSAFE.compareAndSwapObject(this, waitersOffset, q, null)) {
                for (;;) {
                    Thread t = q.thread;
                    if (t != null) {
                        q.thread = null;
                        LockSupport.unpark(t);
                    }
                    WaitNode next = q.next;
                    if (next == null)
                        break;
                    q.next = null; 
                    q = next;
                }
                break;
            }
        }
        done();
        callable = null;
    }

從上面的分析可以看出:異步計算線程啟動后焕刮,主線程(或者其他調(diào)用get()方法的線程)將被放在一個等待對列中,同時被阻塞(通過LockSupport類的park方法)墙杯,知道異步計算線程執(zhí)行完成后配并,等待隊列中的線程將被依次喚醒,并且或得計算結(jié)果高镐。

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末溉旋,一起剝皮案震驚了整個濱河市,隨后出現(xiàn)的幾起案子嫉髓,更是在濱河造成了極大的恐慌观腊,老刑警劉巖,帶你破解...
    沈念sama閱讀 219,589評論 6 508
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件算行,死亡現(xiàn)場離奇詭異梧油,居然都是意外死亡,警方通過查閱死者的電腦和手機州邢,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 93,615評論 3 396
  • 文/潘曉璐 我一進店門儡陨,熙熙樓的掌柜王于貴愁眉苦臉地迎上來,“玉大人,你說我怎么就攤上這事骗村∠油剩” “怎么了?”我有些...
    開封第一講書人閱讀 165,933評論 0 356
  • 文/不壞的土叔 我叫張陵胚股,是天一觀的道長笼痛。 經(jīng)常有香客問我,道長琅拌,這世上最難降的妖魔是什么缨伊? 我笑而不...
    開封第一講書人閱讀 58,976評論 1 295
  • 正文 為了忘掉前任,我火速辦了婚禮财忽,結(jié)果婚禮上倘核,老公的妹妹穿的比我還像新娘。我一直安慰自己即彪,他們只是感情好,可當我...
    茶點故事閱讀 67,999評論 6 393
  • 文/花漫 我一把揭開白布活尊。 她就那樣靜靜地躺著隶校,像睡著了一般。 火紅的嫁衣襯著肌膚如雪蛹锰。 梳的紋絲不亂的頭發(fā)上深胳,一...
    開封第一講書人閱讀 51,775評論 1 307
  • 那天,我揣著相機與錄音铜犬,去河邊找鬼舞终。 笑死,一個胖子當著我的面吹牛癣猾,可吹牛的內(nèi)容都是我干的敛劝。 我是一名探鬼主播,決...
    沈念sama閱讀 40,474評論 3 420
  • 文/蒼蘭香墨 我猛地睜開眼纷宇,長吁一口氣:“原來是場噩夢啊……” “哼夸盟!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起像捶,我...
    開封第一講書人閱讀 39,359評論 0 276
  • 序言:老撾萬榮一對情侶失蹤上陕,失蹤者是張志新(化名)和其女友劉穎,沒想到半個月后拓春,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體释簿,經(jīng)...
    沈念sama閱讀 45,854評論 1 317
  • 正文 獨居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 38,007評論 3 338
  • 正文 我和宋清朗相戀三年硼莽,在試婚紗的時候發(fā)現(xiàn)自己被綠了庶溶。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點故事閱讀 40,146評論 1 351
  • 序言:一個原本活蹦亂跳的男人離奇死亡,死狀恐怖渐尿,靈堂內(nèi)的尸體忽然破棺而出醉途,到底是詐尸還是另有隱情,我是刑警寧澤砖茸,帶...
    沈念sama閱讀 35,826評論 5 346
  • 正文 年R本政府宣布隘擎,位于F島的核電站,受9級特大地震影響凉夯,放射性物質(zhì)發(fā)生泄漏货葬。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點故事閱讀 41,484評論 3 331
  • 文/蒙蒙 一劲够、第九天 我趴在偏房一處隱蔽的房頂上張望震桶。 院中可真熱鬧,春花似錦征绎、人聲如沸蹲姐。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,029評論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽柴墩。三九已至,卻和暖如春凫岖,著一層夾襖步出監(jiān)牢的瞬間江咳,已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 33,153評論 1 272
  • 我被黑心中介騙來泰國打工哥放, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留歼指,地道東北人。 一個月前我還...
    沈念sama閱讀 48,420評論 3 373
  • 正文 我出身青樓甥雕,卻偏偏與公主長得像踩身,于是被迫代替她去往敵國和親。 傳聞我的和親對象是個殘疾皇子犀农,可洞房花燭夜當晚...
    茶點故事閱讀 45,107評論 2 356

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