Kotlin协程(一)

协程能够处理多任务&＃xff0c;但比直接使用线程更为抽象。协程的一项重要功能是能够存储状态&＃xff0c;以便协程可以暂停和恢复。协程可以执行&＃xff0c;也可以不执行。

借助状态&＃xff08;由“连续性”表示&＃xff09;&＃xff0c;部分代码可以在需要移交控制权或需要等待其他协程完成后才能恢复时发出信号。此流程称为“协作式多任务处理”。Kotlin 的协程实现增加了一些协助处理多任务的功能。除了连续性以外&＃xff0c;创建协程还涉及到作用于 CoroutineScope 内的 Job&＃xff08;具有生命周期的可取消工作单元&＃xff09;的内容。CoroutineScope 表示以递归方式对其子级以及这些子级的子级强制执行取消和其他规则的一种上下文。Dispatcher 会管理协程将使用哪个后备线程来执行任务&＃xff0c;从而使开发者无需管理使用新线程的时间和位置。

三、协程

• GlobalScope.launch

  只要应用在运行&＃xff0c;GlobalScope 便允许其中的任何协程运行。鉴于我们讨论的关于主线程的原因&＃xff0c;我们不建议在示例代码之外使用这种方法。在应用中使用协程时&＃xff0c;我们会使用其他作用域。

  launch() 函数会根据括起来的代码&＃xff08;封装在可取消作业对象中&＃xff09;创建协程。launch() 用于无需在协程范围之外返回值的情况。

  我们来看一下 launch() 的完整签名&＃xff0c;以了解协程中的下一个重要概念。

  fun CoroutineScope.launch {context: CoroutineContext &＃61; EmptyCoroutineContext,start: CoroutineStart &＃61; CoroutineStart.DEFAULT,block: suspend CoroutineScope.() -> Unit
}


  在后台&＃xff0c;您传递给 launch 函数的代码块会使用 suspend 关键字进行标记。Suspend 表示代码块或函数可以暂停或恢复。

• runBlocking 简述

  该函数会启动新协程并在新协程完成之前阻塞当前线程。它主要用于在主要函数和测试中的阻塞代码和非阻塞代码之间架起桥梁。该函数在典型的 Android 代码中并不常用。

  import kotlinx.coroutines.*
import java.time.LocalDateTime
import java.time.format.DateTimeFormatterval formatter &＃61; DateTimeFormatter.ISO_LOCAL_TIME
val time &＃61; { formatter.format(LocalDateTime.now()) }suspend fun getValue(): Double {println("entering getValue() at ${time()}")delay(3000)println("leaving getValue() at ${time()}")return Math.random()
}fun main() {runBlocking {val num1 &＃61; getValue()val num2 &＃61; getValue()println("result of num1 &＃43; num2 is ${num1 &＃43; num2}")}
}


• async()

  上述的函数会字啊第一个getValue()执行完毕再执行另外一个。而使用async()修饰的函数则会异步操作&＃xff0c;在第一个函数等待期间执行其它函数

  fun main() {runBlocking {val num1 &＃61; async { getValue() }val num2 &＃61; async { getValue() }println("result of num1 &＃43; num2 is ${num1.await() &＃43; num2.await()}")}
}


  Fun CoroutineScope.async() {context: CoroutineContext &＃61; EmptyCoroutineContext,start: CoroutineStart &＃61; CoroutineStart.DEFAULT,block: suspend CoroutineScope.() -> T
}: Deferred<T>


  async() 函数会返回 Deferred 类型的值。Deferred 是一个可取消的 Job&＃xff0c;可以存储对未来值的引用。使用 Deferred&＃xff0c;您仍然可以调用函数&＃xff0c;就像它会立即返回一个值一样 - Deferred 只充当占位符&＃xff0c;因为您无法确定异步任务将何时返回。Deferred&＃xff08;在其他语言中也称为 promise 或 future&＃xff09;能够保证稍后会向此对象返回一个值。另一方面&＃xff0c;异步任务默认不会阻塞或等待执行。若要启动异步任务&＃xff0c;当前的代码行需要等待 Deferred 的输出&＃xff0c;您可以对其调用 await()。它将会返回原始值

• 何时将函数标记为 suspend

  在前面的示例中&＃xff0c;您可能已经注意到 getValue() 函数也使用 suspend 关键字进行了定义。原因在于它会调用 delay()&＃xff0c;这也是一个 suspend 函数。只要一个函数调用另一个 suspend 函数&＃xff0c;那它也应是 suspend 函数。

  如果这样的话&＃xff0c;为什么我们示例中的 main() 函数不能用 suspend 进行标记呢&＃xff1f;毕竟&＃xff0c;它也调用 getValue()。

  不一定。getValue() 实际上是在传递给 runBlocking() 的函数中调用的&＃xff0c;这是一个 suspend 函数&＃xff0c;类似于传递给 launch() 和 async() 的函数。而 getValue() 不是在 main() 本身中调用的&＃xff0c;runBlocking() 也不是 suspend 函数&＃xff0c;因此 main() 没有用 suspend 标记。如果函数未调用 suspend 函数&＃xff0c;它本身就无需是 suspend 函数。

四、线程的切换

协程是在线程上创建的&＃xff0c;因此如果协程创建在主线程上面的话&＃xff0c;执行网络请求的话依然会使程序出现错误。所以类似于下文的代码是不正确的

viewModelScope.launch() {val jsonBody &＃61; "{ username: \"$username\", token: \"$token\"}"loginRepository.makeLoginRequest(jsonBody)//执行网络请求
}


因此需要使用Dispatcher调度程序将线程切换到子线程&＃xff0c;如下:

viewModelScope.launch(Dispatchers.IO) {//如果不写这个默认就是挂在主线程上面&＃xff0c;程序还是会出现异常val jsonBody &＃61; "{ username: \"$username\", token: \"$token\"}"loginRepository.makeLoginRequest(jsonBody)
}


或者withContext(Dispatchers.IO)使用&＃96;&＃96;将makeLoginRequest改为子线程&＃xff0c;如下:

withContext(Dispatchers.IO) {// Blocking network request code}


当withContext(Dispatchers.IO)中的代码执行完毕后&＃xff0c;程序自动回到原先的线程而无需切换。同时使用withContext(Dispatchers.IO)的函数需要使用挂起suspend来进行修饰。

完整代码如下&＃xff1a;

sealed class Result<out R> {data class Success<out T>(val data: T) : Result<T>()data class Error(val exception: Exception) : Result<Nothing>()
}
private const val loginUrl &＃61; "https://www.baidu.com/"
class LoginRepository(private val responseParser: LoginResponseParser) {// Function that makes the network request, blocking the current threadsuspend fun makeLoginRequest(jsonBody: String): Result<LoginResponse> {val url &＃61; URL(loginUrl)(url.openConnection() as? HttpURLConnection)?.run {requestMethod &＃61; "POST"setRequestProperty("Content-Type", "application/json; utf-8")setRequestProperty("Accept", "application/json")doOutput &＃61; trueoutputStream.write(jsonBody.toByteArray())return Result.Success(responseParser.parse(inputStream))}return Result.Error(Exception("Cannot open HttpURLConnection"))}
}


五、参考链接

1. 协程简介

   https://developer.android.google.cn/codelabs/basic-android-kotlin-training-introduction-coroutines

2. Kotlin协程

   https://developer.android.google.cn/kotlin/coroutines

3. 协程

   https://kotlinlang.org/docs/coroutines-guide.html