Kotlin挂起函数的详细介绍

 更新时间:2022年09月07日 17:11:45   作者:且听真言  
挂起函数用状态机以挂起点将协程的运算逻辑拆分成不同的片段,每次执行协程运行不同的逻辑片段,由此可以知道协程是运行在线程中的,线程的并发处理方式也可以用在协程上

Kotlin 协程的优势:

  • 解决回调地狱的问题。
  • 以同步的方式完成异步任务。

示例:

fun main() {
    runBlocking {
        val a = getA()
        println(a)
        val b = getB(a)
        println(b)
        val c = getC(b)
        println(c)
    }
}
suspend fun getA(): String {
    withContext(Dispatchers.IO) {
        delay(2000L)
    }
    return "A content"
}
suspend fun getB(a: String): String {
    withContext(Dispatchers.IO) {
        delay(2000L)
    }
    return "$a B content"
}
suspend fun getC(b: String): String {
    withContext(Dispatchers.IO) {
        delay(2000L)
    }
    return "$b C content"
}

输出
A content
A content B content
A content B content C content

suspend关键字修饰的方法 就是 挂起函数。挂起函数具备挂起和恢复的能力。挂起就是将程序执行流程转移到其他线程,主线程不阻塞。挂起函数的本质是Callback。

Kotlin编译器检测到suspend关键字修饰的函数,会将挂起函数转换成带有CallBack的函数。

suspend fun getA(): String {
    withContext(Dispatchers.IO) {
        delay(5000L)
        println("now in A process:" + Thread.currentThread())
    }
    /**
     * 这里的代码涉及挂起函数中的操作。
     */
    println("finish A process:" + Thread.currentThread())
    return "A content"
}

将上述Kotlin代码转换成java代码。

 @Nullable
   public static final Object getA(@NotNull Continuation var0) {
      Object $continuation;
      label20: {
         if (var0 instanceof <undefinedtype>) {
            $continuation = (<undefinedtype>)var0;
            if ((((<undefinedtype>)$continuation).label & Integer.MIN_VALUE) != 0) {
               ((<undefinedtype>)$continuation).label -= Integer.MIN_VALUE;
               break label20;
            }
         }
         $continuation = new ContinuationImpl(var0) {
            // $FF: synthetic field
            Object result;
            int label;
 
            @Nullable
            public final Object invokeSuspend(@NotNull Object $result) {
               this.result = $result;
               this.label |= Integer.MIN_VALUE;
               return TestCoroutinue2Kt.getA(this);
            }
         };
      }
      Object $result = ((<undefinedtype>)$continuation).result;
      Object var4 = IntrinsicsKt.getCOROUTINE_SUSPENDED();
      switch(((<undefinedtype>)$continuation).label) {
      case 0:
         ResultKt.throwOnFailure($result);
         CoroutineContext var10000 = (CoroutineContext)Dispatchers.getIO();
         Function2 var10001 = (Function2)(new Function2((Continuation)null) {
            int label;
            @Nullable
            public final Object invokeSuspend(@NotNull Object $result) {
               Object var3 = IntrinsicsKt.getCOROUTINE_SUSPENDED();
               switch(this.label) {
               case 0:
                  ResultKt.throwOnFailure($result);
                  this.label = 1;
                  if (DelayKt.delay(5000L, this) == var3) {
                     return var3;
                  }
                  break;
               case 1:
                  ResultKt.throwOnFailure($result);
                  break;
               default:
                  throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
               }
               String var2 = "now in A process:" + Thread.currentThread();
               System.out.println(var2);
               return Unit.INSTANCE;
            }
            @NotNull
            public final Continuation create(@Nullable Object value, @NotNull Continuation completion) {
               Intrinsics.checkNotNullParameter(completion, "completion");
               Function2 var3 = new <anonymous constructor>(completion);
               return var3;
            }
            public final Object invoke(Object var1, Object var2) {
               return ((<undefinedtype>)this.create(var1, (Continuation)var2)).invokeSuspend(Unit.INSTANCE);
            }
         });
         ((<undefinedtype>)$continuation).label = 1;
         if (BuildersKt.withContext(var10000, var10001, (Continuation)$continuation) == var4) {
            return var4;
         }
         break;
      case 1:
         ResultKt.throwOnFailure($result);
         break;
      default:
         throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
      }
      String var1 = "finish A process:" + Thread.currentThread();
      System.out.println(var1);
      return "A content";
   }

注意:runBlocking 的第二个参数 也是 传入一个 suspend修饰的函数 即挂起函数。

public actual fun <T> runBlocking(context: CoroutineContext, block: suspend CoroutineScope.() -> T): T {

可以发现上面的Continuation 是一个带有泛型参数的Callback,这里的转换称为CPS转换,将原本的同步挂起函数转换成CallBack异步代码。

/**
 * Interface representing a continuation after a suspension point that returns a value of type `T`.
 */
@SinceKotlin("1.3")
public interface Continuation<in T> {
    /**
     * The context of the coroutine that corresponds to this continuation.
     */
    public val context: CoroutineContext
    /**
     * Resumes the execution of the corresponding coroutine passing a successful or failed [result] as the
     * return value of the last suspension point.
     */
    public fun resumeWith(result: Result<T>)
}

注意:挂起函数,只能在协程中被调用,或者被其他挂起函数调用。

为什么挂起函数可以调用挂起函数,而普通函数不能调用挂起函数?

fun main() {
    doA() //这里会报错
}
suspend fun doA() {
}
 public static final void main() {
   }
   // $FF: synthetic method
   public static void main(String[] var0) {
      main();
   }
 @Nullable
   public static final Object doA(@NotNull Continuation $completion) {
      return Unit.INSTANCE;
   }

被调用的挂起函数需要传入一个Continuation, 没有被suspend修饰的函数是没有Continuation参数的,所以没法在普通函数中调用挂起函数,普通函数没有Continuation。

挂起函数最终都是在协程中被调用,协程提供了挂起函数运行的环境。

到此这篇关于Kotlin挂起函数的详细介绍的文章就介绍到这了,更多相关Kotlin挂起函数内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • Android中屏幕密度和图片大小的关系详解

    Android中屏幕密度和图片大小的关系详解

    这篇文章主要介绍了Android中屏幕密度和图片大小的关系详解的相关资料,需要的朋友可以参考下
    2017-05-05
  • kotlin代码中!!操作符的清楚方法

    kotlin代码中!!操作符的清楚方法

    这篇文章主要给大家介绍了关于kotlin代码中!!操作符的清楚方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2018-06-06
  • Flutter Future异步操作详细讲解

    Flutter Future异步操作详细讲解

    这篇文章主要介绍了Flutter Future异步操作,future是Future类的对象,其表示一个T类型的异步操作结果。如果异步操作不需要结果,则future的类型可为Future
    2023-03-03
  • Kotlin启动协程的三种方式示例详解

    Kotlin启动协程的三种方式示例详解

    这篇文章主要为大家介绍了Kotlin启动协程的三种方式示例详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-12-12
  • android自定义控件实现简易时间轴(2)

    android自定义控件实现简易时间轴(2)

    这篇文章主要为大家详细介绍了android自定义控件实现简易时间轴的第二篇,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2022-01-01
  • android新建草稿删除后下次开机还会显示保存的草稿

    android新建草稿删除后下次开机还会显示保存的草稿

    android 新建一个草稿,保存,然后全部删除会话,关机再开机后还会显示保存的草稿,下面与大家分享下具体的解决方法
    2013-06-06
  • Android实现IOS相机滑动控件

    Android实现IOS相机滑动控件

    这篇文章主要为大家详细介绍了Android实现IOS相机滑动控件的相关资料,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2016-08-08
  • 花样使用Handler与源码分析

    花样使用Handler与源码分析

    今天小编就为大家分享一篇关于花样使用Handler与源码分析,小编觉得内容挺不错的,现在分享给大家,具有很好的参考价值,需要的朋友一起跟随小编来看看吧
    2019-01-01
  • Android使用ContentResolver搜索手机通讯录的方法

    Android使用ContentResolver搜索手机通讯录的方法

    这篇文章主要介绍了Android使用ContentResolver搜索手机通讯录的方法,结合实例形式分析了Android中ContentResolver操作手机通讯录的具体步骤与相关实现技巧,需要的朋友可以参考下
    2016-01-01
  • Android 自动化测试经验分享 UiObejct.getFromParent()的使用方法

    Android 自动化测试经验分享 UiObejct.getFromParent()的使用方法

    本篇文章对Android中UiObejct.getFromParent()的使用进行了详细的分析介绍。需要的朋友参考下
    2013-05-05

最新评论