双重检查 golang 中的锁定 - 为什么需要 mutex.RLock()？

Question

我有一段代码，它对对象的初始化进行了双重检查锁定。func checkSyncProducer() {    mutex.RLock()    if syncProducer == nil {        mutex.RUnlock()        mutex.Lock()        defer mutex.Unlock()        if syncProducer == nil {            syncProducer  = createSyncKafkaProducer() //this func will initialize syncProducer.        }    } else {        defer mutex.RUnlock()    }}这段代码在mutex.RLock()第一次 nil 检查之前。为什么需要这样？（它在页面中有解释，但我无法理解）并且它不会增加开销，因为每次调用 checkSyncProducer 时都会获取和释放读取锁。在获取读锁之前是否应该再进行一次 nil 检查，例如：func checkSyncProducer() {    if syncProducer == nil {        mutex.RLock()        if syncProducer == nil {            mutex.RUnlock()            mutex.Lock()            defer mutex.Unlock()            if syncProducer == nil {                createSyncKafkaProducer()            }        } else {            defer mutex.RUnlock()        }    }}第一个 nil 检查将确保 RLock 不会被不必要地占用。我对么？

Answer 1

如果你没有获取 RLock 来读取syncProducer，那就是数据竞争，因为另一个 goroutine 可能会更新它。

如果你假设对指针变量的读/写是原子的，这看起来是无害的——活泼的读syncProducer永远不会导致不正确的行为。如果你不做这个原子假设，如果你不走运的话，读取可能只产生指针的一些字节，你的程序就会崩溃。

根据您使用的体系结构、机器字长、编译器版本等，这可能会也可能不会。但这RLock避免了任何担忧。

与其显式地乱用 RWLocks，不如使用它（假设目标是懒惰地初始化一个变量）：

var (

    syncOnce sync.Once

    syncProducerInternal *syncProducerType

)

func syncProducer() *syncProducerType {

    syncOnce.Do(func() { syncProducerInternal = createSyncKafkaProducer() })

    return syncProducerInternal

}

然后需要同步生产者的代码可以调用该syncProducer()函数来获取它，而永远不会看到 nil 指针。

Answer 2

这是必需的，因为检查是只读操作。改为执行 RW 锁是可能的，但这意味着一次只有一个 goroutine 可以进行检查。