Kotlin 编程实践

协程与结构化并发

｜

213

参阅

use 函数在 10.1 节讨论过。

13.5

取消协程

问题

如何取消运行在协程上的异步任务。

解决方案

使用 launch 构建器返回的 Job 引用，或者使用 withTimeout 或 withTimeoutOrNull

函数中的一个。

讨论

launch 构建器返回了一个 Job 类型的实例，它可以用于取消一个协程。示例 13-11 基

于 Kotlin 参考指南中的示例。

示例 13-11：取消一个作业

fun main() = runBlocking {

val job = launch {

repeat(100) { i ->

println("job: I'm waiting $i...")

delay(100L)

}

}

delay(500L)

println("main: That's enough waiting")

job.cancel()

job.join()

println("main: Done")

}

launch 构建器返回了一个 Job 实例，它被赋值给了一个局部变量，然后使用 repeat

函数启动 100 个协程。

在 launch 代码块的外部，main 函数已经厌倦了等待所有协程，因此取消了这个作业。

join 函数等待作业完成，然后程序退出。该程序的输出如下：

job: I'm waiting 0...

job: I'm waiting 1...

214

｜

第

13

章

job: I'm waiting 2...

job: I'm waiting ...