协程是什么?
进程、线程,在开发中使用最多的就是线程,比如主线程、子线程,而且操作系统里最小可操作的单元就是线程,那协程又是什么?协程是比线程更小的单位,但并不是说在操作系统里最小可操作单元就从线程变成了协程,而是协程依然运行在线程上,协程是在语言上实现的比线程更小的单位。
那么你可能有疑问,既然协程还是运行在线程上,那直接使用线程不就好了吗?但问题是往往我们用不好线程,首先创建一个线程的成本很高,在 Android 中创建一个线程,大约要消耗 1M 的内存,而且,如果使用线程池,线程间数据的同步也是一个非常麻烦复杂的事情,所以就有了协程:
可以看作是轻量级线程,创建一个协程的成本很低
可以轻松的挂起和恢复操作
支持阻塞线程的协程和不阻塞线程的协程
可以更好的实现异步和并发
如果简单来理解 Kotlin 协程的话,就是封装好的线程池
Kotlin协程库:Kotlin.coroutines
实现协程的库是 Kotlin.coroutines,点击查看Kotlin.coroutines在 Github 上的源码。
Kotlin 是一门支持 多平台的语言,所以 Kotlin.coroutines 也是支持多平台的,包括:
Kotlin/JS
Kotlin/Native 包括 PC 和 Android
我们使用 Kotlin.coroutines 的 Android 版本。
给 Android 工程添加 Kotlin 协程库
suspend 方法
在前面介绍协程的代码里,有个不起眼的函数:
suspendfunfetchData():String{
delay(2000)return"content"
}
suspend方法是协程里的特有方法。
suspend 方法的定义
suspend方法的声明很简单,只需在方法 或 Lambda 定义前面加suspend关键字即可。
suspend 方法的使用限制
suspend 方法使用由限制,只能有两个地方允许使用suspend方法:
在协程内部使用
在另一个 suspend 方法里使用
如果你在一个普通方法内存使用 suspend 方法,是会报语法错误的。
suspend 方法的功能
suspend 方法能够使协程执行暂停,等执行完毕后在返回结果,同时不会阻塞线程。
是不是很神奇,只暂停协程,但不阻塞线程。
而且暂停协程里方法的执行,直到方法返回结果,这样也不用写 Callback 来取结果,可以使用同步的方式来写异步代码。
Coroutine context 与 Coroutine dispatchers
想要使用协程,还有两个重要的元素:
Coroutine context:协程上下文
Coroutine dispatchers :协程调度
Coroutine context:协程上下文
协程上下文里是各种元素的集合。具体的之后的文章在讲。
Coroutine dispatchers :协程调度
我们已经知道协程是运行在线程上的,我们获取数据后要更新 UI ,但是在 Android 里更新 UI 只能在主线程,所以我们要在子线程里获取数据,然后在主线程里更新 UI。这就需要改变协程的运行线程,这就是 Coroutine dispatchers 的功能了。
Coroutine dispatchers 可以指定协程运行在 Android 的哪个线程里。
我们先看下 dispatchers 有哪些种类:
var job = GlobalScope.launch(Dispatchers.Main) {
var content = fetchData()
Log.d("Coroutine",content)
}
GlobalScope.launch 后面的Dispatchers.Main就是指定协程在 Android 主线程里运行。
那么,如何切换线程呢?如下:
GlobalScope.launch(Dispatchers.IO) {
...
withContext(Dispatchers.Main) {
...
}
}
使用withContext切换协程,上面的例子就是先在 IO 线程里执行,然后切换到主线程。
Android 开发中使用 协程
讲完协程的基本用法,你还是不知道改如何用到自己的代码里,这里给出一个最基本的用法,后续的使用方法会不断补充。
首先 MainActivity 要 实现CoroutineScope这个接口,CoroutineScope的实现教由代理类MainScope,
class MainActivity : AppCompatActivity(),CoroutineScope by MainScope()
class MainActivity : AppCompatActivity(),CoroutineScope by MainScope() {
override fun onCreate(savedInstanceState: Bundle?) {
super.onCreate(savedInstanceState)
setContentView(R.layout.activity_main)
setSupportActionBar(toolbar)
//加载并显示数据
loadDataAndShow()
}
fun loadDataAndShow(){
GlobalScope.launch(Dispatchers.IO) {
//IO 线程里拉取数据
var result = fetchData()
withContext(Dispatchers.Main){
//主线程里更新 UI
text.setText(result)
}
}
}
suspend fun fetchData():String{
delay(2000)
return "content"
}
override fun onDestroy() {
super.onDestroy()
//取消掉所有协程内容
cancel()
}
}
网友评论