如何避免Jetpack Compose中MutableState更新触发的IllegalStateException？

问题根源 #

这个异常的核心原因是：Compose通过mutableStateOf创建的SnapshotMutableState，其读写操作必须处于Compose快照上下文或Android主线程中。你的代码存在两个风险点：

1. RxJava的网络请求回调（doOnNext）默认在后台线程执行，直接更新State会触发快照校验失败；
2. MyModel的init块在remember实例化时立即调用refresh，此时State尚未被Compose快照系统完全注册，更新操作会导致快照状态不一致。

可行解决方案 #

1. 强制State更新在主线程执行 #

RxJava的网络请求通常运行在后台线程，需要通过observeOn(AndroidSchedulers.mainThread())将回调切换到主线程，这是解决问题的核心：

fun refresh() {
    RestClient.getNumber()
        .observeOn(AndroidSchedulers.mainThread()) // 切换到主线程执行State更新
        .doOnNext { i ->
            number.value = i
        }
        .take(1)
        .subscribe()
}

2. 延迟refresh调用时机，避开Compose初始化阶段 #

将refresh的调用从MyModel的init块，移到Compose的LaunchedEffect中，确保在Composable进入组合、快照系统就绪后再执行异步操作：

// 在你的Composable代码中
val myModel = remember { MyModel() }
LaunchedEffect(Unit) {
    myModel.refresh() // 仅在Composable首次进入组合时触发
}

// 修改后的MyModel类
class MyModel() {
    companion object
    val number = mutableStateOf(0)

    fun refresh() {
        RestClient.getNumber()
            .observeOn(AndroidSchedulers.mainThread())
            .doOnNext { i ->
                number.value = i
            }
            .take(1)
            .subscribe()
    }
}

LaunchedEffect是Compose专为异步操作设计的生命周期组件，能保证操作在安全的时机执行。

3. 快照上下文直接更新（备选方案） #

如果因特殊需求无法切换到主线程，可以使用Snapshot.withMutableSnapshot强制在快照上下文中执行State更新，但这种方式复杂度较高，仅作为主线程方案的补充：

doOnNext { i ->
    Snapshot.withMutableSnapshot {
        number.value = i
    }
}

4. 管理RxJava订阅生命周期（避免内存泄漏） #

额外注意：原代码中subscribe()未管理订阅生命周期，易引发内存泄漏。可以用CompositeDisposable统一管理：

class MyModel() {
    companion object
    val number = mutableStateOf(0)
    private val disposables = CompositeDisposable()

    fun refresh() {
        val disposable = RestClient.getNumber()
            .observeOn(AndroidSchedulers.mainThread())
            .doOnNext { i ->
                number.value = i
            }
            .take(1)
            .subscribe()
        disposables.add(disposable)
    }

    fun clearSubscriptions() {
        disposables.clear()
    }
}

// 在Composable中用DisposableEffect清理
val myModel = remember { MyModel() }
DisposableEffect(Unit) {
    onDispose {
        myModel.clearSubscriptions() // Composable销毁时清理订阅
    }
}

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