Kotlin中Completable局部变量temp值异常问题咨询

问题描述 #

多次并发调用getCompletable()时，onTerminate回调中打印的temp变量有时为false。已确认每次函数调用中temp都被设置为true，但部分调用里它在onTerminate中变回false。原本认为每个函数调用的temp会占用独立内存地址，且因被Completable回调引用不会被垃圾回收，理应在onTerminate中始终为true。

相关代码：

fun getCompletable() {
    var temp = false
    return Completable.create {
        acquireLock()
        temp = true
        ...
    }.onTerminate {
        println(temp) // temp is sometimes true and sometimes false
    }
}

原因分析 #

核心问题是线程可见性缺失，具体细节如下：

• Kotlin中，lambda捕获可变局部变量（var temp）时，会自动将变量包装到一个内部引用类（比如BooleanRef）中，这个类的value字段没有volatile修饰符。
• 当Completable.create块在某个线程中执行temp = true时，修改的是这个引用类的value字段，但由于没有内存屏障，该修改不会立即同步到主内存。
• 而onTerminate回调可能在另一个线程执行，它读取的是自己线程缓存中的value旧值（false），从而出现打印false的情况。
• 你提到的“每个函数调用的temp占用独立内存地址”是对的，每个getCompletable()调用都会生成独立的引用类实例，但实例内的value字段缺乏多线程可见性保障，导致跨线程读取不一致。

解决方案 #

方案1：使用AtomicBoolean保证可见性 #

将普通的var temp替换为AtomicBoolean，它的get()和set()操作自带内存可见性保障：

import java.util.concurrent.atomic.AtomicBoolean

fun getCompletable() {
    val temp = AtomicBoolean(false)
    return Completable.create {
        acquireLock()
        temp.set(true)
        ...
    }.onTerminate {
        println(temp.get()) // 始终能读取到最新值
    }
}

方案2：自定义volatile委托（可选） #

如果坚持使用普通变量，可以通过自定义委托添加volatile修饰，保证内存可见性：

import kotlin.properties.ReadWriteProperty
import kotlin.reflect.KProperty

fun <T> volatile(initialValue: T): ReadWriteProperty<Any?, T> =
    object : ReadWriteProperty<Any?, T> {
        @Volatile
        private var value = initialValue

        override fun getValue(thisRef: Any?, property: KProperty<*>): T = value
        override fun setValue(thisRef: Any?, property: KProperty<*>, value: T) {
            this.value = value
        }
    }

fun getCompletable() {
    var temp by volatile(false)
    return Completable.create {
        acquireLock()
        temp = true
        ...
    }.onTerminate {
        println(temp)
    }
}

额外注意点 #

• 已确认temp = true每次都执行，可排除“代码未执行到赋值逻辑就触发onTerminate”的情况；
• acquireLock()的阻塞逻辑只会延迟Completable执行，不会直接导致temp值回退，核心矛盾还是线程可见性问题。

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