Android Kotlin协程带/不带中断的取消及生命周期自动取消实现

两种单任务取消模式的实现 #

协程原生机制完全可以覆盖AsyncTask/Executors时期的两类取消需求，不需要额外改造：

• 带线程中断的取消模式（对应原cancel(true)逻辑）
  • 实现逻辑：直接对启动的Job调用cancel()方法，默认会向任务运行所在线程发送中断信号，所有可响应中断的阻塞操作（包括Thread.sleep()、Java原生阻塞IO、Socket读写）会立刻抛出InterruptedException终止执行
  • 注意要点：
    • 优先使用协程自带的可中断suspend函数替代原生阻塞调用（比如用delay()替代Thread.sleep()），这类函数和协程取消机制深度绑定，收到取消信号会立刻终止
    • 对于无法替换的第三方阻塞API，用runInterruptible包裹成可中断的suspend块，即可正常响应协程的取消中断，示例：

      // 原阻塞调用
      Thread.sleep(5000)
      // 替换为可被协程中断的版本
      runInterruptible { Thread.sleep(5000) }
      

    • 禁止随意catch并吞掉InterruptedException、CancellationException，要让中断异常向上传递给协程机制，否则会出现取消失效
• 不带线程中断的取消模式（对应原cancel(false)逻辑）
  • 实现逻辑：将正在运行的阻塞操作块用NonCancellable上下文包裹，此时调用cancel()仅会标记协程的取消状态，不会触发线程中断，块内的阻塞操作会正常执行完成
  • 执行完阻塞块后，在所有后续逻辑前检查isActive状态，如果协程已被取消，直接终止逻辑不执行回调，示例：

    launch(Dispatchers.IO) {
        withContext(NonCancellable) {
            // 块内操作不会被协程中断，cancel时会正常跑完
            Thread.sleep(5000)
        }
        // 出块后检查取消状态
        if (!isActive) return@launch
        // 只有协程活跃时才执行后续回调
        withContext(Dispatchers.Main) { updateUI() }
    }
    

Activity销毁时自动批量取消任务的配置 #

不需要手动维护任务集合，通过官方提供的生命周期绑定Scope即可实现自动取消，在1.4.1版本的协程库中已经完全支持：

• 核心配置：
  • 引入和协程版本兼容的androidx.lifecycle:lifecycle-runtime-ktx:2.2.0+依赖，获取Activity生命周期绑定的lifecycleScope扩展
  • 所有和Activity生命周期关联的任务，统一通过lifecycleScope启动，不要手动创建无绑定的CoroutineScope(Dispatchers.Main)
• 工作逻辑：
  • lifecycleScope会自动监听Activity的生命周期，当Activity触发onDestroy回调时（包括屏幕旋转、系统回收、用户退出等场景），会自动调用cancel()取消scope下所有关联的Job，不需要手动编写批量取消的逻辑
  • 基础调用示例：

    class MainActivity : AppCompatActivity() {
        override fun onCreate(savedInstanceState: Bundle?) {
            super.onCreate(savedInstanceState)
            // 直接使用绑定生命周期的Scope启动任务
            val taskJob = lifecycleScope.launch(Dispatchers.IO) {
                // 替换原有的Thread.sleep为可中断版本
                runInterruptible { Thread.sleep(5000) }
                if (!isActive) return@launch
                withContext(Dispatchers.Main) { updateResult() }
            }
            // 手动取消单个任务时，直接调用对应Job的cancel方法即可
            // taskJob.cancel()
        }
    }
    

常见失效场景的原因说明 #

• 调用cancel()后Thread.sleep未中断：通常是因为直接调用原生阻塞方法，没有包装成可被协程中断的suspend块，且未正确处理线程中断信号，用runInterruptible包装、替换可中断suspend函数即可解决
• Activity重建后任务依然触发回调：通常是因为使用了未绑定生命周期的自定义CoroutineScope，Activity销毁时没有触发Scope的取消，替换为生命周期绑定的lifecycleScope即可解决
• cancel()后回调依然触发：通常是因为回调逻辑执行前没有检查协程的isActive状态，哪怕协程已经被标记为取消，只要没有状态检查，后续逻辑依然会执行，在切线程执行回调前补充状态检查即可解决

内容的提问来源于stack exchange，提问作者android developer