返回

Kotilin挂起函数的超时机制与取消方法

Android

Kotlin 中的超时与取消

在异步编程中，超时和取消是至关重要的概念，它们使我们能够控制和管理挂起函数的执行。Kotlin 协程为超时和取消提供了完善的机制，使开发人员能够编写健壮、可控的并发代码。

超时

超时允许我们为挂起函数设置一个时间限制，如果在该时间限制内函数未完成，则自动取消该函数。使用 withTimeout 函数可设置超时：

try {
    val result = withTimeout(1000) {
        // 挂起函数代码
    }
} catch (e: TimeoutException) {
    // 超时处理逻辑
}

如果挂起函数在 1000 毫秒内完成，则 withTimeout 将返回其结果，否则将引发 TimeoutException。

取消

取消允许我们在挂起函数完成之前手动终止它。使用 cancelAndJoin 函数可取消挂起函数：

val job = launch {
    // 挂起函数代码
}

// 取消挂起函数
job.cancelAndJoin()

如果挂起函数在取消后仍成功完成，则 cancelAndJoin 将返回其结果，否则将引发 CancellationException。

取消相关异常

当挂起函数被取消时，可能会抛出以下异常：

  • JobCancellationException： 当挂起函数被手动取消时抛出。
  • CancellationException： 当挂起函数由于任何原因被取消时抛出，包括超时和协程范围被取消。

取消策略

Kotlin 提供了多种取消策略来控制取消的行为：

  • Cooperative Cancellation： 挂起函数自己检查取消状态并取消自身。这是默认策略。
  • Supervisor Job： Supervisor Job 创建一个新的协程范围，其中子协程的取消不会影响父协程。
  • Dispatchers： Dispatchers 决定挂起函数执行的位置，不同的调度程序具有不同的取消行为。

代码示例

以下代码示例展示了 Kotlin 中超时和取消的使用：

// 使用 withTimeout 设置超时
try {
    val result = withTimeout(1000) {
        delay(2000)
        "Hello World"
    }
} catch (e: TimeoutException) {
    println("Timed out!")
}

// 使用 cancelAndJoin 取消挂起函数
val job = launch {
    delay(2000)
    println("Done!")
}

// 取消挂起函数
job.cancelAndJoin()

结论

超时和取消是 Kotlin 协程中的强大工具，它们使我们能够在异步编程中处理时间限制和手动终止挂起函数。通过理解这些机制，我们可以编写更健壮、更可靠的协程代码。

常见问题解答

  1. 如何判断一个挂起函数是否被取消？

    • 使用 isActive 属性，如果为 false，则表明函数已被取消。

  2. 超时和取消有什么区别？

    • 超时是自动取消，而取消是手动取消。

  3. Cooperative Cancellation 和 Supervisor Job 有什么区别？

    • Cooperative Cancellation 要求挂起函数自行检查取消状态，而 Supervisor Job 保护子协程免受父协程取消的影响。

  4. 哪些 Dispatchers 支持取消？

    • Dispatchers.Default 和 Dispatchers.IO 支持取消，而 Dispatchers.Unconfined 不支持取消。

  5. 如何在协程上下文中传播取消？

    • 使用 CancellationPropagator 可以在协程上下文中传播取消。