【kotlin】- 攜程的掛起和恢復

簡介

使用kotlin攜程,難免會使用到攜程的掛起特性奋早,正因為這些特性解決了kotlin等待異步執(zhí)行結(jié)果的回調(diào)地獄兜粘,下面將從源碼的角度來分析攜程的掛起和恢復原理绞绒。

技巧

方法執(zhí)行可以通過打印線程堆棧來看

    public static void printStackTrace(String msg) {
        StackTraceElement[] stackTrace = Thread.currentThread().getStackTrace();

        println(Thread.currentThread() + ", message: [" + msg + "]");
        if (stackTrace == null || stackTrace.length < 2) {
            println("empty stack");
            return;
        }

        for (int i = 2; i < stackTrace.length; i++) {
            println("\tat " + stackTrace[i]);
        }
    }

    private static void println(Object object) {
        System.out.println(object);
    }

例子先行

  • 公用代碼
     fun treadName(): String = Thread.currentThread().name
    
     suspend fun doSuspendOne(): Int {
        delay(1000L) // 假設(shè)我們在這里做了一些有用的事
        println("${treadName()}======doSuspendOne")
        return 13
    }
    
    suspend fun doSuspendTwo(): Int {
        delay(500L) // 假設(shè)我們在這里也做了一些有用的事
        println("${treadName()}======doSuspendTwo")
        return 29
    }
    
  • 第一個例子
    fun main() {
        runBlocking {
            doSuspendOne()
            doSuspendTwo()
        }
        println("${treadName()}======main")
    }
    
    輸出如下:
    main======doSuspendOne
    main======doSuspendTwo
    main======main
    
    Process finished with exit code 0
    
  • 第二個例子
    suspend fun main() {
       doSuspendOne()
       doSuspendTwo()
       println("${treadName()}======main")
    }
    
    輸出如下:
    kotlinx.coroutines.DefaultExecutor======doSuspendOne
    kotlinx.coroutines.DefaultExecutor======doSuspendTwo
    kotlinx.coroutines.DefaultExecutor======main
    
    Process finished with exit code 0
    
  • 第三個例子
     suspend fun main() {
         GlobalScope.launch {
             println("${treadName()}======launch1111")
             delay(300)
             println("${treadName()}======launch")
         }
         runBlocking {
             println("${treadName()}======runBlocking")
             doSuspendOne()
             doSuspendTwo()
         }
         println("${treadName()}======main")
     }
    
    輸出如下:
    DefaultDispatcher-worker-1======launch1111
    main======runBlocking
    DefaultDispatcher-worker-1======launch
    main======doSuspendOne
    main======doSuspendTwo
    main======main
    
    Process finished with exit code 0
    
  • 第四個例子
    suspend fun main() {
        GlobalScope.launch {
            println("${treadName()}======launch1111")
            delay(300)
            println("${treadName()}======launch")
        }
        println("${treadName()}======main")
        Thread.sleep(3000)
    }
    
    輸出如下
    main======main
    DefaultDispatcher-worker-1======launch1111
    DefaultDispatcher-worker-1======launch
    
    Process finished with exit code 0
    

掛起

特點是:掛起而不阻塞線程,這里要清楚一點耕腾,掛起的本質(zhì)是切線程见剩,并且在相應(yīng)的邏輯處理完成之后,再重新切回線程扫俺。掛起使協(xié)程體的操作被return而停止苍苞,等待恢復,它阻塞的是協(xié)程體的操作牵舵,并未阻塞線程。

掛起函數(shù)底層實現(xiàn)

剛開始學習kotlin的同學可能不知道怎么分析kotlin相關(guān)功能代碼倦挂,特別是語法糖相關(guān)的畸颅,其實不管kotlin語法糖再多,它最終要通過編譯方援,脫糖生成字節(jié)碼没炒,總是能夠分析的。

下面將通過源碼層面進行攜程掛起恢復的講解犯戏,這里只給出關(guān)鍵的源碼位置送火,如果大家想一步步跟蹤代碼的執(zhí)行邏輯,可以寫一個簡單的apk先匪,里面包含簡單的攜程代碼种吸,利用Android Studio進行編譯和脫糖相關(guān)處理,在用jadx進程反編譯呀非,查看坚俗。

通過 jdax發(fā)現(xiàn)部分代碼不能反編譯,那么我們可以結(jié)合Android Studio提供的kotlin反編譯工具進行查看岸裙。

  • 負責協(xié)程體邏輯的處理(BaseContinuationImpl)

    internal abstract class BaseContinuationImpl(  
         // completion:實參是一個AbstractCoroutine  
         public val completion: Continuation<Any?>?  
     ) : Continuation<Any?>, CoroutineStackFrame, Serializable {  
         public final override fun resumeWith(result: Result<Any?>) {  
                     ...
                         try {  
                             // 調(diào)用invokeSuspend方法猖败,協(xié)程體真正開始執(zhí)行  
                             val outcome = invokeSuspend(param)  
                             // invokeSuspend方法返回值為COROUTINE_SUSPENDED,resumeWith方法被return降允,結(jié)束執(zhí)行恩闻,說明執(zhí)行了掛起操作  
                             if (outcome === COROUTINE_SUSPENDED) return  
                             // 協(xié)程體執(zhí)行成功的結(jié)果  
                             Result.success(outcome)  
                         } catch (exception: Throwable) {  
                             // 協(xié)程體出現(xiàn)異常的結(jié)果  
                             Result.failure(exception)  
                         }  
                     releaseIntercepted()   
                    
                     if (completion is BaseContinuationImpl) {               
                         ...  
                     } else {  
                         completion.resumeWith(outcome)  
                         return  
                    ...
    

    invokeSuspend()的執(zhí)行就是協(xié)程體的執(zhí)行,當invokeSuspend()返回值為COROUTINE_SUSPENDED時剧董,會執(zhí)行return操作幢尚,resumeWith()的執(zhí)行被結(jié)束掉,協(xié)程體的操作也被結(jié)束掉了翅楼,而COROUTINE_SUSPENDED代表協(xié)程發(fā)生掛起侠草。

    通過反編譯可以發(fā)現(xiàn)我們編寫的攜程體會被轉(zhuǎn)換成invokeSuspend方法調(diào)用 ,以這個例子進行反編譯(我用的Android Studio自帶的kotlin工具犁嗅,和通過jadx反編譯出來有所不同边涕,但是掛起和恢復的邏輯都一樣的)。

    suspend fun doSuspendOne(): Int {
        delay(1000) // 假設(shè)我們在這里做了一些有用的事
        println("${treadName()}======doSuspendOne")
        return 13
    }
    
    fun main(): Unit = runBlocking{
        doSuspendOne()
    }
    

    看一下invokeSuspend方法:

            public final Object invokeSuspend(@NotNull Object $result) {
            ...
             switch(this.label) {
             case 0:
                ...
                this.label = 1;
                if (TestKt.doSuspendOne(this) == var2) {
                   return var2;
                }
                break;
            ...
             }
            ...
           }
    

    doSuspendOne函數(shù)實現(xiàn):

    public static final Object doSuspendOne(@NotNull Continuation var0) {
     Object $continuation;
     ...
       Object var5 = IntrinsicsKt.getCOROUTINE_SUSPENDED();
       switch(((<undefinedtype>)$continuation).label) {
           case 0:
           ResultKt.throwOnFailure($result);
           ((<undefinedtype>)$continuation).label = 1;
           if (DelayKt.delay(1000L, (Continuation)$continuation) == var5) {
           return var5;
       }
           break;
           case 1:
           ResultKt.throwOnFailure($result);
           break;
           default:
           throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
       }
    
       String var1 = KotlinCoroutinesTestKt.treadName() +   "======doSuspendOne";
       boolean var2 = false;
       System.out.println(var1);
       return Boxing.boxInt(13);
    }
    

    結(jié)合源碼看一下,默認情況下label==0功蜓,i==0,執(zhí)行l(wèi)abel = 1賦值操作园爷,及調(diào)用掛起函數(shù)delay(...),此處判斷delay(...)方法返回值為coroutine_suspended時式撼,就會返回 coroutine_suspended童社,也就是當delay(...)內(nèi)存在掛起操作的時候它的返回值就是coroutine_suspended

    假設(shè)delay(...)掛起函數(shù)內(nèi)執(zhí)行了掛起操作著隆,delay(...)方法結(jié)束并返回coroutine_suspended扰楼,resumeWith()方法在收到返回值coroutine_suspended也進行了return操作,resumeWith()和invokeSuspend()方法執(zhí)行都結(jié)束了美浦, println日志打印并沒有得到執(zhí)行弦赖,協(xié)程掛起并不是阻塞了當前的線程(通過上面第三個例子輸出可以看出),而是執(zhí)行了return操作浦辨,結(jié)束了協(xié)程體的調(diào)用蹬竖。

    掛起函數(shù)內(nèi)執(zhí)行掛起操作的時候會返回coroutine_suspended標志,結(jié)束協(xié)程體的運行流酬,使協(xié)程掛起币厕,接下來看下協(xié)程提供的掛起函數(shù)中是如何操作的。

  • 攜程恢復
    恢復外部協(xié)程時芽腾,通過線程調(diào)度旦装,將協(xié)程在指定線程運行,這樣也就可以在掛起恢復時摊滔,重新切回線程,再次觸發(fā)invokeSuspend()同辣,根據(jù)label狀態(tài)值,執(zhí)行下一個代碼片惭载。

    結(jié)論
    在DispatchedCoroutine中旱函,重寫了afterCompletion()及afterResume(),并且afterCompletion()調(diào)用afterResume()描滔,而afterResume()中首先判斷了協(xié)程是否被掛起棒妨,如已掛起則恢復外部的協(xié)程『ぃ恢復外部協(xié)程時券腔,同樣是通過線程調(diào)度,將協(xié)程在指定線程運行拘泞,這樣也就可以在掛起恢復時纷纫,重新切回線程,再次觸發(fā)invokeSuspend(),根據(jù)label狀態(tài)值陪腌,執(zhí)行下一個代碼片辱魁。本質(zhì)就是:將攜程體代碼分成一個個執(zhí)行代碼塊烟瞧,通過label控制執(zhí)行那一個代碼塊,當執(zhí)行到需要掛起的代碼塊會掛起染簇,然后返回結(jié)束協(xié)調(diào)體執(zhí)行参滴,當掛起部分恢復時,重新在指定線程調(diào)用invokeSuspend方法锻弓,這是label變成下一個要執(zhí)行的代碼塊的值砾赔。

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個濱河市青灼,隨后出現(xiàn)的幾起案子暴心,更是在濱河造成了極大的恐慌,老刑警劉巖杂拨,帶你破解...
    沈念sama閱讀 222,681評論 6 517
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件专普,死亡現(xiàn)場離奇詭異,居然都是意外死亡扳躬,警方通過查閱死者的電腦和手機脆诉,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 95,205評論 3 399
  • 文/潘曉璐 我一進店門甚亭,熙熙樓的掌柜王于貴愁眉苦臉地迎上來贷币,“玉大人,你說我怎么就攤上這事亏狰∫畚疲” “怎么了?”我有些...
    開封第一講書人閱讀 169,421評論 0 362
  • 文/不壞的土叔 我叫張陵暇唾,是天一觀的道長促脉。 經(jīng)常有香客問我,道長策州,這世上最難降的妖魔是什么瘸味? 我笑而不...
    開封第一講書人閱讀 60,114評論 1 300
  • 正文 為了忘掉前任,我火速辦了婚禮够挂,結(jié)果婚禮上旁仿,老公的妹妹穿的比我還像新娘。我一直安慰自己孽糖,他們只是感情好枯冈,可當我...
    茶點故事閱讀 69,116評論 6 398
  • 文/花漫 我一把揭開白布。 她就那樣靜靜地躺著办悟,像睡著了一般尘奏。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上病蛉,一...
    開封第一講書人閱讀 52,713評論 1 312
  • 那天炫加,我揣著相機與錄音瑰煎,去河邊找鬼。 笑死琢感,一個胖子當著我的面吹牛丢间,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播驹针,決...
    沈念sama閱讀 41,170評論 3 422
  • 文/蒼蘭香墨 我猛地睜開眼烘挫,長吁一口氣:“原來是場噩夢啊……” “哼!你這毒婦竟也來了柬甥?” 一聲冷哼從身側(cè)響起饮六,我...
    開封第一講書人閱讀 40,116評論 0 277
  • 序言:老撾萬榮一對情侶失蹤,失蹤者是張志新(化名)和其女友劉穎苛蒲,沒想到半個月后卤橄,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 46,651評論 1 320
  • 正文 獨居荒郊野嶺守林人離奇死亡臂外,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 38,714評論 3 342
  • 正文 我和宋清朗相戀三年窟扑,在試婚紗的時候發(fā)現(xiàn)自己被綠了。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片漏健。...
    茶點故事閱讀 40,865評論 1 353
  • 序言:一個原本活蹦亂跳的男人離奇死亡嚎货,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出蔫浆,到底是詐尸還是另有隱情殖属,我是刑警寧澤,帶...
    沈念sama閱讀 36,527評論 5 351
  • 正文 年R本政府宣布瓦盛,位于F島的核電站洗显,受9級特大地震影響,放射性物質(zhì)發(fā)生泄漏原环。R本人自食惡果不足惜挠唆,卻給世界環(huán)境...
    茶點故事閱讀 42,211評論 3 336
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望嘱吗。 院中可真熱鬧玄组,春花似錦、人聲如沸柜与。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,699評論 0 25
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽弄匕。三九已至颅悉,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間迁匠,已是汗流浹背剩瓶。 一陣腳步聲響...
    開封第一講書人閱讀 33,814評論 1 274
  • 我被黑心中介騙來泰國打工驹溃, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留,地道東北人延曙。 一個月前我還...
    沈念sama閱讀 49,299評論 3 379
  • 正文 我出身青樓豌鹤,卻偏偏與公主長得像,于是被迫代替她去往敵國和親枝缔。 傳聞我的和親對象是個殘疾皇子布疙,可洞房花燭夜當晚...
    茶點故事閱讀 45,870評論 2 361

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