Android Jetpack Compose：如何终止produceState中启动的协程？

目标 #

我有一个计算密集型函数calculateItems: suspend (String) -> Sequence<String>，需要实现以下功能：

• 计算过程中实时展示进度，同时保证UI响应流畅
• 用户输入变更时自动终止当前计算任务
• 用户点击按钮后重新启动计算流程

初步实现思路 #

我使用produceState来管理计算状态，将计算任务委托给Dispatchers.Default调度器避免阻塞主线程，同时遍历序列输出的每一项来更新进度状态。代码示例如下：

val totalSize = 255 // 示例中使用固定总数
var input by rememberSaveable(stateSaver = TextFieldValue.Saver) {
    mutableStateOf(TextFieldValue("Test Input"))
}
var doCalculation by rememberSaveable(input) {
    mutableStateOf(false)
}
val resultState by produceState(
    State.Null as State,
    input,
    doCalculation,
) {
    value = DealingState.Null
    if (!doCalculation) {
        value = DealingState.Null
        return@produceState
    }

    value = DealingState.Loading(
        progress = 0,
        required = totalSize,
    )

    launch(Dispatchers.Default) {
        runCatching {
            val resultList = mutableListOf<String>()
            calculateItems(input).forEach {
                resultList.add(it)
                value = State.Loading(
                    progress = resultList.size,
                    required = totalSize,
                )
            }
            value = State.Success(resultList)
        }.getOrElse {
            value = State.Failure(it)
        }
    }
}

已尝试的任务取消方案 #

为了实现输入变更时取消当前计算，我尝试了两种方案：

1. 为计算任务创建专属协程作用域，每次触发新状态时先取消该作用域

val scope = CoroutineScope(Dispatchers.Default)
val resultState by produceState(...) {
    scope.cancel()
    // ... 后续计算逻辑
    scope.launch(Dispatchers.Default) {...}
}

2. 保存launch返回的Job实例，每次启动新计算前取消该Job（也尝试过取消其子Job）

var job: Job? = null
val resultState by produceState(...) {
    job?.cancel() // 也曾尝试job?.cancelChildren()
    // ... 后续计算逻辑
    job = launch(Dispatchers.Default) {...}
}

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