Kotlin协程：多launch块访问类变量始终读取旧值问题排查

你遇到的核心问题是多线程/协程环境下的变量可见性缺失。

普通的var someVar: Boolean没有任何线程同步语义，当someFun1在Main线程的协程中修改这个变量时，修改操作可能只写入了当前CPU的缓存，而someFun2所在的协程（即使同样在Main线程，也可能因为JVM的内存模型优化）读取的是缓存中的旧值，导致始终看不到更新后的true。

解决方案1：使用AtomicBoolean #

AtomicBoolean是Java并发包提供的原子类型，它的读写操作既保证原子性，也保证跨线程的可见性，适合这种简单的布尔状态同步：

import java.util.concurrent.atomic.AtomicBoolean

class CertainClass {
    // 替换普通Boolean为AtomicBoolean
    private val someVar = AtomicBoolean(false)

    suspend fun doIt() {
        certainScope.launch(Dispatchers.Main) {
            someFun2()
        }

        certainScope.launch(Dispatchers.Main) {
            someFun1()
        }
    }

    suspend fun someFun1() {
        // ...
        someVar.set(true)
        // ...
    }

    suspend fun someFun2() {
        while (earth.exists()) {
            val currentValue = someVar.get()
            print(currentValue)
            if (currentValue) {
                // 执行逻辑
            }
            delay(1000)
        }
    }
}

解决方案2：用@Volatile修饰变量 #

在Kotlin中可以通过@Volatile注解标记变量，强制变量的读写操作直接访问主内存，绕过CPU缓存，从而保证可见性：

class CertainClass {
    @Volatile
    var someVar: Boolean = false

    // 其余代码保持不变
}

解决方案3：使用Kotlin协程的MutableStateFlow（推荐） #

如果是基于协程的场景，更推荐使用Kotlin官方提供的StateFlow，它专门为协程设计，不仅保证状态的可见性，还能自动向订阅者推送状态更新，代码更符合协程的设计理念：

import kotlinx.coroutines.flow.MutableStateFlow
import kotlinx.coroutines.flow.asStateFlow
import kotlinx.coroutines.flow.collect

class CertainClass {
    // 私有可变流，对外暴露只读的StateFlow
    private val _someVar = MutableStateFlow(false)
    val someVar = _someVar.asStateFlow()

    suspend fun doIt() {
        certainScope.launch(Dispatchers.Main) {
            someFun2()
        }

        certainScope.launch(Dispatchers.Main) {
            someFun1()
        }
    }

    suspend fun someFun1() {
        // ...
        _someVar.value = true
        // ...
    }

    suspend fun someFun2() {
        // 方式1：收集状态更新，无需主动循环（更推荐）
        someVar.collect { currentValue ->
            print(currentValue)
            if (currentValue) {
                // 执行逻辑
                // 若需要终止流程，可取消当前协程或结合takeWhile等操作符
            }
        }

        // 方式2：保留原有循环，每次读取最新状态
        /*
        while (earth.exists()) {
            val currentValue = someVar.value
            print(currentValue)
            if (currentValue) {
                // 执行逻辑
            }
            delay(1000)
        }
        */
    }
}

额外检查点 #

除了可见性问题，建议确认someFun1确实被执行到：可以在someFun1的someVar = true前后添加日志，验证这行代码是否真的被调用，避免因为协程取消、执行顺序等其他问题导致状态未更新。

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