为什么你需要用协程?
- Kotlin推出了协程,但Java没有(只有某些框架有这个概念)
- 告别回调地狱(提高代码的可读性)
- 面试需要(别逼无奈) :)
我用Kotlin快一年了吧,Kotlin是真的香,但是Kotlin的协程,听过,看过,但我没用过,嘻嘻,可能是太懒了吧!!!
这个星期在官网摸了摸🐟,感觉还不错,但还是有很多地方不懂的,慢慢学吧,还请大家多多指教!!!
直接看看来官网的例子吧。(有一部分我去掉了,我想用我的理解说一下协程)
import kotlinx.coroutines.*
fun main() {
GlobalScope.launch {
}
}
这就是传说中的协程,skr
你没看错,这就是开启协程的一种写法,是不是看起来很简单,嗯,我讲完了,协程就这么简单,再见晚安
当然,官网的每个例子哪有难的,难的话,我就不跟他玩了。
再来看一个关键词suspend,这个意思是挂起,我理解的是比如一条流水线上,我看一个东西坏了,我把他吊起来,但他不会影响流水线,我修好了,我又放到流水线上去,是可控的,我想咋样就咋样。
开启协程、吊起、放下一条龙服务
单纯一个函数一个函数的讲,那我也讲不完,我也讲不清啊,那下面,我简单的讲下,Retrofit搭配协程构建的简单的网络库
先分析下,先不说RxJava,单纯用Retrofit请求网络的话
//demo例子,不需要管细节
enqueue(object : Callback<T> {
override fun onFailure(call: Call<T>, t: Throwable) {
//错误回调,告诉返回结果
mListener.onFail(t)
}
override fun onResponse(call: Call<T>, response: Response<T>?) {
//成功回调,告诉返回结果
mListener.onSuccess(t)
}
})
一般都是这样写吧,观察者模式,然后回调地狱模式开启。
那么加入协程会变成怎么样了,当然协程的作用肯定不止这一点,但我觉得从这里能更容易看出协程的好处。
第一步,开启协程
fun requestDataToUI(){ GlobalScope.launch(Dispatchers.Main) {
try{
//从这里开始请求网络
getXXData() //成功回调
}catch(t : Throwable){
//失败回调
//to do something
}
}
}
这里需要大概了解的是:
- GlobalScope.launch():是个顶层的开启协程的方法,可以看官网都有
- Dispatchers.Main:是个调度器,是个枚举,里面有几个调度器类型,Main这个就认为把网络请求到的数据切换到主线程就可以啦
- 这里的try{ }catch():暂时先不看,在后面会讲到
在IO线程请求网络
suspend fun getXXData() =withContext(Dispatchers.IO) {
requestData()
}
这里需要了解的是:
- suspend:吊起了,才能有更多的主动性的操作。
- withcontext():协程内,切换到指定的上下文
- Dispatchers.IO:跟上面那个Main调度器一个妈生的
将回调转换成协程的挂起函数
suspend fun requestData() : String =suspendCancellableCoroutine { continuation ->
//获取当前协程实例
ServiceBuilder.weatherService.getWeathers().enqueue(object : Callback<String> {
override fun onFailure(call: Call<String>, t: Throwable) {
continuation.resumeWithException(t)
}
override fun onResponse(call: Call<String>, response: Response<String>?) {
val body =response.body()
if (body != null){
continuation.resume(body)//这看看源码也能大概知道什么意思,还有个resumeWith也可以了解一下
}else{
continuation.resumeWithException(NullPointerException("Response Body is Null : $response"))
}
}
})
}
这里估计理解的比较累点:
- enqueue():这个可以不用看了,你肯定懂的
- suspendCancellableCoroutine{ continuation ->}:获取当前协程的实例,关键就在这,我们获取到了当前的实例,那么能做什么呢?
- resumeWithException:放下协程了,不吊他了,但会抛出异常(这相当于观察者模式的错误回调)
- resume:恢复协程,放下协程了,告诉协程,我是成功的(这相当于观察者模式的成功回调)
成功或者错误的回调都在第一步的try{ } catch( )注释中,通过协程的主动挂起和恢复协程,把回调地狱给解决了,🐂🍺
当然这只是个简单的讲协程的例子,例子中很多代码都还可以处理,比如:
- loadingView的统一处理
- 请求网络方法的封装(写出扩展函数,网上一大堆)
- 取消网络请求等等
想要具体用好协程API,还需对协程更深入的了解。小弟表示,我只会简单的用用。等了解透了,再分享给大家,谢谢大家,么么哒