欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Suspend函數(shù)與回調(diào)的互相轉(zhuǎn)換示例詳解

 更新時(shí)間：2023年01月15日 10:19:05   作者：Pika  
這篇文章主要為大家介紹了Suspend函數(shù)與回調(diào)的互相轉(zhuǎn)換示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪

前言

我們?cè)賮硪黄陉P(guān)于kotlin協(xié)程的故事，我們都知道在Coroutine沒有出來之前，我們對(duì)于異步結(jié)果的處理都是采用回調(diào)的方式進(jìn)行，一方面回調(diào)層次過多的話，容易導(dǎo)致“回調(diào)地獄”，另一方法也比較難以維護(hù)。當(dāng)然，我們并不是否定了回調(diào)本身，回調(diào)本身同時(shí)也是具備很多優(yōu)點(diǎn)的，比如符合代碼閱讀邏輯，同時(shí)回調(diào)本身也是比較可控的。這一期呢，我們就是來聊一下，如何把回調(diào)的寫法變成suspend函數(shù)，同時(shí)如何把suspend函數(shù)變成回調(diào)，從而讓我們更加了解kotlin協(xié)程背后的故事

回調(diào)變成suspend函數(shù)

來一個(gè)回調(diào)

我們以一個(gè)回調(diào)函數(shù)作為例子，當(dāng)我們normalCallBack在一個(gè)子線程中做一些處理，比如耗時(shí)函數(shù)，做完就會(huì)通過MyCallBack回調(diào)onCallBack，這里返回了一個(gè)Int類型，如下：

var myCallBack:MyCallBack?= null
interface MyCallBack{
    fun onCallBack(result: Int)
}
fun normalCallBack(){
    thread { 
        // 比如做一些事情
        myCallBack?.onCallBack(1)
    }
}

轉(zhuǎn)化為suspend函數(shù)

此時(shí)我們可以通過suspendCoroutine函數(shù)，內(nèi)部其實(shí)是通過創(chuàng)建了一個(gè)SafeContinuation并放到了我們suspend函數(shù)本身（block本身）啟動(dòng)了一個(gè)協(xié)程，我們之前在聊一聊Kotlin協(xié)程"低級(jí)"api 這篇文章介紹過

public suspend inline fun <T> suspendCoroutine(crossinline block: (Continuation<T>) -> Unit): T {
    contract { callsInPlace(block, InvocationKind.EXACTLY_ONCE) }
    return suspendCoroutineUninterceptedOrReturn { c: Continuation<T> ->
        val safe = SafeContinuation(c.intercepted())
        block(safe)
        safe.getOrThrow()
    }
}

這時(shí)候我們就可以直接寫為，從而將回調(diào)消除，變成了一個(gè)suspend函數(shù)。

suspend fun mySuspend() = suspendCoroutine<Int> {
    thread {
        // 比如做一些事情
        it.resume(1)
    }
}

當(dāng)然，如果我們想要支持一下外部取消，比如當(dāng)前頁面銷毀時(shí)，發(fā)起的網(wǎng)絡(luò)請(qǐng)求自然也就不需要再請(qǐng)求了，就可以通過suspendCancellableCoroutine創(chuàng)建，里面的Continuation對(duì)象就從SafeContinuation（見上文）變成了CancellableContinuation，變成了CancellableContinuation有一個(gè)invokeOnCancellation方便，支持在協(xié)程體被銷毀時(shí)的邏輯。

public suspend inline fun <T> suspendCancellableCoroutine(
    crossinline block: (CancellableContinuation<T>) -> Unit
): T =
    suspendCoroutineUninterceptedOrReturn { uCont ->
        val cancellable = CancellableContinuationImpl(uCont.intercepted(), resumeMode = MODE_CANCELLABLE)
        /*
         * For non-atomic cancellation we setup parent-child relationship immediately
         * in case when `block` blocks the current thread (e.g. Rx2 with trampoline scheduler), but
         * properly supports cancellation.
         */
        cancellable.initCancellability()
        block(cancellable)
        cancellable.getResult()
    }

此時(shí)我們就可以寫出以下代碼

suspend fun mySuspend2() = suspendCancellableCoroutine<Int> {
    thread {
        // 比如做一些事情
        it.resume(1)
    }
    it.invokeOnCancellation { 
        // 取消邏輯
    }
}

suspend函數(shù)變成回調(diào)

見到了回調(diào)如何變成suspend函數(shù)，那么我們反過來呢？有沒有辦法？當(dāng)然有啦！當(dāng)時(shí)suspend函數(shù)中有很多種區(qū)分，我們一一區(qū)分一下

//直接返回的suspend函數(shù)
suspend fun myNoSuspendFunc():Int{
    return 1
}

//調(diào)用suspendCoroutine后直接resume的suspend函數(shù)
suspend fun myNoSuspendFunc() = suspendCoroutine<Int> {
        continuation ->
    continuation.resume(1)
}

//調(diào)用suspendCoroutine后異步執(zhí)行的suspend函數(shù)（這里異步可以是單線程也可以是多線程，跟線程本身無關(guān)，只要是異步就會(huì)觸發(fā)掛起）
suspend fun myRealSuspendFunc() = suspendCoroutine<Int> {
    thread {
        Thread.sleep(300)
        it.resume(2)
    }

那么我們來想一下，這里真正發(fā)起掛起的函數(shù)是哪個(gè)？通過代碼其實(shí)我們可以猜到，真正掛起的函數(shù)只有最后一個(gè)myRealSuspendFunc，其他都不是真正的掛起，這里的掛起是什么意思呢？我們從協(xié)程的狀態(tài)就可以知道，當(dāng)前處于CoroutineSingletons.COROUTINE_SUSPENDED時(shí)，就是掛起狀態(tài)。我們回歸一下，一個(gè)suspend函數(shù)有哪幾種情況

這里的1，2，3就分別對(duì)應(yīng)著上文demo中的例子

  • 直接返回結(jié)果，不需要進(jìn)入狀態(tài)機(jī)判斷，因?yàn)楸旧砭蜎]有啟動(dòng)協(xié)程
  • 進(jìn)入了協(xié)程，但是不需要進(jìn)行SUSPEND狀態(tài)就已經(jīng)有了結(jié)果，所以直接返回了結(jié)果
  • 進(jìn)入了SUSPEND狀態(tài)，之后才能獲取結(jié)果

這里我們就不貼出來源碼了，感興趣可自己看Coroutine的實(shí)現(xiàn)，這里我們要明確一個(gè)概念，一個(gè)Suspend函數(shù)的運(yùn)行機(jī)制，其實(shí)并不依靠了協(xié)程本身。

對(duì)應(yīng)代碼表現(xiàn)就是，這個(gè)函數(shù)的返回結(jié)果可能就是直接返回結(jié)果本身，另一種就是通過回調(diào)本身通知外部（這里我們還會(huì)以例子說明）

suspend函數(shù)轉(zhuǎn)換為回調(diào)

這里有兩種情況，我們分別以kotlin代碼跟java代碼表示：

kotlin代碼

由于kotlin可以直接通過suspend的擴(kuò)展函數(shù)startCoroutine啟動(dòng)一個(gè)協(xié)程，

fun myRealSuspendCallBack(){
    ::myRealSuspendFunc.startCoroutine(object :Continuation<Int>{
       當(dāng)前環(huán)境
        override val context: CoroutineContext
            get() = Dispatchers.IO
        結(jié)果
        override fun resumeWith(result: Result<Int>) {
            if(result.isSuccess){
                myCallBack?.onCallBack(result.getOrDefault(0))
            }
        }
    })
}

其中Result就是一個(gè)內(nèi)聯(lián)類，屬于kotlin編譯器添加的裝飾類，在這里我們無論是1，2，3的情況，都可以在resumeWith 中獲取到結(jié)果，在這里通過callback回調(diào)即可

@JvmInline
public value class Result<out T> @PublishedApi internal constructor(
    @PublishedApi
    internal val value: Any?
) : Serializable {

Java代碼

這里我們更正一個(gè)誤區(qū)，就是suspend函數(shù)只能在kotlin中使用/Coroutine協(xié)程只能在kotlin中使用，這個(gè)其實(shí)是錯(cuò)誤的，java代碼也能夠調(diào)起協(xié)程，只不過麻煩了一點(diǎn)，至少官方是沒有禁止的。 比如我們需要調(diào)用startCoroutine，可直接調(diào)用

ContinuationKt.startCoroutine();

當(dāng)然，我們也能夠直接調(diào)用suspend函數(shù)

Object result = CallBack.INSTANCE.myRealSuspendFunc(new Continuation<Integer>() {
    @NonNull
    @Override
    public CoroutineContext getContext() {
        //這里啟動(dòng)的環(huán)境其實(shí)協(xié)程沒有用到，讀者們可以思考一下為什么！這里就當(dāng)一個(gè)謎題啦！可以在評(píng)論區(qū)說出你的想法（我會(huì)在評(píng)論區(qū)解答）
        return (CoroutineContext) Dispatchers.getIO();
        //return EmptyCoroutineContext.INSTANCE;
    }
    @Override
    public void resumeWith(@NonNull Object o) {
        情況3
        Log.e("hello","resumeWith result is "+ o +" is main "+ (Looper.myLooper() == Looper.getMainLooper()));
          // 回調(diào)處理即可
          myCallBack?.onCallBack(result)
    }
});
if(result != IntrinsicsKt.getCOROUTINE_SUSPENDED()){
    情況1，2
    Log.e("hello","func result is "+ result);
      // 回調(diào)處理即可
      myCallBack?.onCallBack(result)
}

這里我們需要注意的是，這里java代碼比kotlin多了一個(gè)判斷，同時(shí)resumeWith的參數(shù)不再是Result，而是一個(gè)Object

if(result != IntrinsicsKt.getCOROUTINE_SUSPENDED()){
}

這里脫去了kotlin給我們添加的各種外殼，其實(shí)這就是真正的對(duì)于suspend結(jié)果的處理（只不過kotlin幫我們包了一層）

我們上文說過，suspend函數(shù)對(duì)應(yīng)的三種情況，這里的1，2都是直接返回結(jié)果的，因?yàn)闆]有走到SUSPEND狀態(tài)（IntrinsicsKt.getCOROUTINE_SUSPENDED()）這里需要讀者好好閱讀上文，因此 result != IntrinsicsKt.getCOROUTINE_SUSPENDED()，就會(huì)直接走到這里，我們就直接拿到了結(jié)果

if(result != IntrinsicsKt.getCOROUTINE_SUSPENDED()){
}

如果屬于情況3，那么這里的result就不再是一個(gè)結(jié)果，而是當(dāng)前協(xié)程的狀態(tài)標(biāo)記罷了，此時(shí)當(dāng)協(xié)程完成執(zhí)行的時(shí)候（調(diào)用resume的時(shí)候），就會(huì)回調(diào)到resumeWith，這里的Object類型o才是經(jīng)過SUSPEND狀態(tài)的結(jié)果！

總結(jié)

經(jīng)過我們suspend跟回調(diào)的互相狀態(tài)，能夠明白了suspend背后的邏輯與掛起的細(xì)節(jié)，希望能幫到你

以上就是Suspend函數(shù)與回調(diào)的互相轉(zhuǎn)換示例詳解的詳細(xì)內(nèi)容，更多關(guān)于Suspend函數(shù)回調(diào)轉(zhuǎn)換的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

相關(guān)文章

最新評(píng)論