什么是协程(Coroutine)
简单来说,协程像是轻量级的线程,但并不完全是线程。
首先,协程可以让你顺序地写异步代码,极大地降低了异步编程带来的负担;
其次,协程更加高效。多个协程可以共用一个线程。一个 App 可以运行的线程数是有限的,但是可以运行的协程数量几乎是无限的;
协程实现的基础是可中断的方法(suspending functions)。可中断的方法可以在任意的地方中断协程的执行,直到该可中断的方法返回结果或者执行完成。
可中断的方法(suspending functions) "suspend" 修饰方法
suspend fun suspendingFunction() : Int {
// Long running task
return 0
}
协程上下文(Coroutine Context)
//运行在UI 线程 , 这种写法会造成UI阻塞
CoroutineScope(Dispatchers.Main).launch() {
val datas = RetrofitClient.create(GetDataAPI::class.java).getDatas()
}
//将网络请求,文件读写等其他方法放在IO线程中
withContext(Dispatchers.IO) {
val datas = RetrofitClient.create(GetDataAPI::class.java).getDatas()
}
//最终写法
CoroutineScope(Dispatchers.Main).launch() {
withContext(Dispatchers.IO) {
val datas = RetrofitClient.create(GetDataAPI::class.java).getDatas()
}
}
目前为止,我们认识了两个 dispatcher,下面我们详细介绍一下所有的 dispatcher 的使用场景。
Default
当我们未指定 dispatcher 的时候会默认使用,当然,我们也可以明确设置使用它。它一般用于 CPU 密集型的任务,特别是涉及到计算、算法的场景。它可以使用和 CPU 核数一样多的线程。正因为是密集型的任务,同时运行多个线程并没有意义,因为 CPU 将会很繁忙。
IO
它用于输入/输出的场景。通常,涉及到会阻塞线程,需要等待另一个系统响应的任务,比如:网络请求、数据库操作、文件读写等,都可以使用它。因为它不使用 CPU ,可以同一时间运行多个线程,默认是数量为 64 的线程池。Android App 中有很多网络请求的操作,所以你可能会经常用到它。
UnConfined
如果你不在乎启动了多少个线程,那么你可以使用它。它使用的线程是不可控制的,除非你特别清楚你在做什么,否则不建议使用它。
Main
这是 UI 相关的协程库里面的一个 dispatcher,在 Android 编程中,它使用的是 UI 线程。
协程构造器(Coroutine Builders)
runBlocking
这个协程构造器会阻塞当前线程,直到协程内的所有任务执行完毕。
launch
这个协程构造器很重要,因为它可以很轻易地创建一个协程,你可能会经常用到它。和 runBlocking 相反的是,它不会阻塞当前线程(前提是我们使用了合适的 dispatcher)。
launch 方法会返回一个 Job,Job 继承了协程上下文(CoroutineContext)。
job.join
将当前协程阻塞执行王当前异步在按照顺序执行下一个异步。
job.cancel
这个方法可以取消所有与其关联的子 Job。也就是相当于取消当前异步。
job.cancel() 是一个普通方法,所以它不必运行在协程内部。
async
async 允许并行地运行多个子线程任务,它不是一个可中断方法,所以当调用 async 启动子协程的同时,后面的代码也会立即执行。async 通常需要运行在另外一个协程内部,它会返回一个特殊的 Job,叫作 Deferred。
Deferred 有一个新的方法叫做 await(),它是一个可中断的方法,当我们需要获取 async 的结果时,需要调用 await() 方法等待结果。调用 await() 方法后,会中断当前协程,直到其返回结果。
作用域(Scope)
Global scope
它是一个全局的作用域,如果协程的运行周期和 App 的生命周期一样长的话,创建协程的时候可以使用它。所以它不应该和任何可以被销毁的组件绑定使用。
viewModelScope
这是一个跟ViewModel绑定的作用域,ViewModel跟Activity/Fragment生命周期绑定,所以viewModelScope的作用域跟Activity/Fragment生命周期一样。
回调方式转为协程
如果你已经考虑将协程用于现有的项目,你可能会考虑怎么将现有的回调风格的代码转为协程:
suspend fun suspendAsyncLogin(username: String, password: String): User =
suspendCancellableCoroutine { continuation ->
userService.doLoginAsync(username, password) { user ->
continuation.resume(user)
}
suspendCancellableCoroutine() 这个方法返回一个 continuation 对象,continuation 可以用于返回回调的结果。只要调用 continuation.resume() 方法,这个回调结果就可以作为这个可中断方法的结果返回给协程。
转载自
https://blog.csdn.net/weixin_33701617/article/details/91375647