引入携程所需库
第一步:项目级build.gradle中
buildscript { ext.kotlin_coroutines = '1.3.1' }
第二步:Module级别build.gradle中
dependencies { // 👇 依赖协程核心库 implementation "org.jetbrains.kotlinx:kotlinx-coroutines-core:$kotlin_coroutines" // 👇 依赖当前平台所对应的平台库,如Android或js implementation "org.jetbrains.kotlinx:kotlinx-coroutines-android:$kotlin_coroutines" //协程的声明周期库,该库可以选加,是让协程的生命周期和Activity的周期保持一致 implementation 'androidx.lifecycle:lifecycle-runtime-ktx:2.3.0-alpha02' }
注:核心库和平台库版本需要保持一致
协程是什么
- 协程:是一个线程框架,最核心的部分是【非阻塞式】和【挂起】;就是launch{协程部分}async{协程部分}
相关名词
1、GloabScope:全局范围
2、Coroutine:协程
3、suspend:挂起、暂停
- a、代码执行到用suspend标识的函数时会挂起,且这种挂起是不会阻塞的,不会影响当前线程的执行,而这种所谓的挂起,其实就是切一个线程,且在函数执行完毕会自动将线程切回来的调度工作。
- b、用suspend标识的函数只能运行在协程中;或者被另一个被suspend标识的函数调用,其实最终还是运行在一个协程中。
- c、suspend本身是不能真正实现挂起的,他的作用主要是一个提醒,是创建者对使用者的提醒,该函数是一个耗时函数,且是用挂起的方式在后台运行,所以请在协程中调用我
- d、suspend的意义:传递CoroutineContext
相关方法介绍
runBlocking :一般用于 单元测试中,是线程阻塞的
launch(Dispatchers.IO){}:可以用来切线程
coroutineScope.launch(Dispatchers.IO) {
...
launch(Dispatchers.Main){
...
launch(Dispatchers.IO) {
...
launch(Dispatchers.Main) {
...
}
}
}
}
withContext(){}:切换线程,当需要频繁的进行线程切换时,因为可以自动切回原来的线程,所以相应的代码嵌套层次没那么多,并在闭包内的逻辑执行结束后自动切回原来的线程,继续执行
coroutineScope.launch(Dispatchers.Main) {
...
withContext(Dispatchers.IO) {
...
}
...
withContext(Dispatchers.IO) {
...
}
...
}
Async{}:返回的协程实现了Deferred。可以使用wait()方法
创建携程的方法
方法一:使用runBlocking 顶层函数,适用于单元测试的情况,是线程阻塞的,一般正常的业务开发不会使用
runBlocking{个人理解:此次相当于开启一个线程,但是会阻塞当前线程,相当于一个耗时任务??? getImage(imageId) }
方法二:使用GlobalScope 单例对象,直接调用launch开启协程,不会阻塞线程,但是实际开发中也一般不会使用,因为它的生命周期和APP的生命周期是一致的
GlobalScope.launch{ getImage(imageId) }
方法三:通过CoroutineContext创建一个CoroutineScope(接口)对象,需要一个类型为CoroutineContext的参数。开发中推荐这种方法,--coroutineContext?????
val coroutineScope = CoroutineScope(coroutineContext) coroutineScope.launch{ getImage(imageId) }
方法四:主要用于在一个协程中开启另一个协程,直接在普通代码中无法使用
launch{ }
方法五:该方法与launch类似,也是在协程中使用
async{ }
async 和 launch对比
相同点:都可以用来启动一个协程,返回的都是Coroutine
不同点:
async返回的Coroutine还实现了Deferred(意思是延迟,也就是结果稍后才能拿到。)接口。可以使用await暂停函数来返回result
launch可启动新协程而不将结果返回给调用方
async使用场景:如现在需要展示公司LOGO和个人头像,但是需要等待两者都返回了,才可以去显示,两者同时进行,然后等较慢的执行完毕就可以显示了,所花费的时间就是两个中较长的一个,而不是两者之和
coroutineScope.launch(Dispatchers.Main) {
// 👇 async 函数启动新的协程
val avatar: Deferred = async { api.getAvatar(user) } // 获取用户头像
val logo: Deferred = async { api.getCompanyLogo(user) } // 获取用户所在公司的 logo
// 👇 👇 获取返回值
show(avatar.await(), logo.await()) // 更新 UI
}
挂起的本质
什么是挂起:挂起就是稍后会自动切回来的操作
在协程中,我们挂起的对象既不是线程,也不是函数,而是我们挂起的对象是协程,就是launch和async函数中的闭包的代码块,而launch和async或者其他函数创建的协程在执行到某一个suspend函数的时候,这个函数就会被挂起,或者说从当前线程中脱离。
自定义suspend函数
-
什么时候需要自定义suspend函数
比如某个函数时比较函数的,可以将他协程suspend函数,这就是原则 耗时操作分为:I/O操作和CPU计算工作,比如文件读写,网络交互,图片的模糊处理。 另一种耗时操作:如事情本身并不慢,但是因为某些原因需要等5s或者特定时间再执行,这种也可以定义为suspend
-
具体如何实现自定义
1、给函数加上suspend关键字 2、用withContext将函数内容包住(方便执行完毕,自动切回原始线程) 3、针对需要等待的耗时操作,我们可以直接使用另一个挂起函数delay()