4. Happens-Before 关系：Go 内存模型、同步原语保证、channel 通信规则

在并发编程中，Happens-Before 是定义内存操作可见性与有序性的核心规则。Go 语言的内存模型（Memory Model）通过 Happens-Before 关系，规定了在一个 goroutine 中对变量的写入何时能被另一个 goroutine 安全地观察到。理解这一关系是编写无 data race 并发代码的基础。

4.1 什么是 Happens-Before

Happens-Before 是一个偏序关系，记作 A → B，表示操作 A 在操作 B 之前发生，且 A 的结果对 B 可见。若两个操作没有 Happens-Before 关系，则它们并发执行，可能产生 data race。

核心原则： 若一个 goroutine 对变量的写入与另一个 goroutine 对该变量的读取没有 Happens-Before 关系，则读取可能看到旧值或未定义值。

4.2 Go 内存模型中的 Happens-Before 规则

Go 内存模型定义了以下基本规则：

规则 描述 示例
程序顺序 单个 goroutine 内，代码书写顺序即为 Happens-Before 顺序 a = 1; b = 2 → a=1 先于 b=2
同步原语 Mutex/RWMutex 的 Unlock 先于另一个 goroutine 的 Lock mu.Unlock() → mu.Lock()
Channel 通信 向 channel 发送数据先于从该 channel 接收完成 ch <- v → <-ch
WaitGroup wg.Wait() 返回先于所有 wg.Done() 完成 wg.Done() → wg.Wait()
Once once.Do(f) 中 f 的返回先于所有调用者从 Do 返回 f() → once.Do()
atomic atomic.Store 先于对应的 atomic.Load Store → Load

4.3 同步原语保证

Go 的同步原语通过内存屏障（memory barrier）实现 Happens-Before 语义，确保数据在 goroutine 间正确同步。

4.3.1 Mutex 与 RWMutex

  • Unlock → Lock：一个 goroutine 调用 mu.Unlock() 后，另一个 goroutine 调用 mu.Lock() 成功时，Unlock 之前的所有写入对 Lock 之后的代码可见。
  • RLock → RUnlock：读锁同样保证顺序，但多个读锁之间不互斥。
var mu sync.Mutex
var data int

// goroutine 1
data = 42
mu.Unlock()

// goroutine 2
mu.Lock()
fmt.Println(data) // 保证看到 42
mu.Unlock()

4.3.2 WaitGroup

wg.Add() 必须在 wg.Wait() 之前调用，wg.Done() 的完成先于 wg.Wait() 返回。这保证了所有 goroutine 的写入在 Wait 返回后可见。

4.3.3 Once

sync.Once 确保初始化函数只执行一次，且初始化完成先于所有后续调用。常用于单例模式或全局配置加载。

var once sync.Once
var config map[string]string

func loadConfig() {
    config = map[string]string{"key": "value"}
}

func GetConfig() map[string]string {
    once.Do(loadConfig) // loadConfig 的写入对后续 GetConfig 调用可见
    return config
}

4.4 Channel 通信规则

Channel 是 Go 中最重要的同步机制，其 Happens-Before 规则非常明确：

操作 Happens-Before 关系 说明
无缓冲 channel 发送 发送先于接收完成 发送 goroutine 在数据被接收前阻塞
无缓冲 channel 接收 接收完成先于发送返回 接收 goroutine 在数据到达前阻塞
缓冲 channel 发送 发送先于接收开始 数据写入缓冲区后，接收方可读取
缓冲 channel 接收 接收完成先于下一次发送 缓冲区有空位后，发送方可继续
close(ch) close 先于从已关闭 channel 接收到的零值 关闭后接收方立即收到零值
最佳实践： 使用无缓冲 channel 进行同步时，发送和接收成对出现，天然形成 Happens-Before 链。缓冲 channel 适合解耦生产者和消费者，但需注意缓冲区大小对同步语义的影响。

4.5 Happens-Before 关系图

下图展示了 goroutine 间通过同步原语和 channel 建立的 Happens-Before 关系链：

Happens-Before 关系示意图 Happens-Before 关系链 Goroutine A 写 data = 42 mu.Unlock() Goroutine B mu.Lock() 读 data Happens-Before Unlock 之前的写入（data=42）对 Lock 之后的读取可见 形成完整的 Happens-Before 链：写 → Unlock → Lock → 读 Channel 通信 Happens-Before ch <- v (发送) Happens-Before <-ch (接收)

4.6 常见误区与避坑

常见误区：
  • 误以为 time.Sleep 提供同步： time.Sleep 不建立 Happens-Before 关系，不能保证数据可见性。
  • 误以为 channel 关闭后接收顺序： 关闭 channel 后，所有接收者会立即收到零值，但多个接收者之间没有顺序保证。
  • 误以为缓冲 channel 的发送立即可见： 缓冲 channel 的发送在数据写入缓冲区后对接收方可见，但接收方可能尚未开始读取。

4.7 总结

Happens-Before 关系是 Go 并发编程的基石。通过同步原语（Mutex、WaitGroup、Once）和 channel 通信，开发者可以精确控制 goroutine 间的数据可见性。牢记以下要点：

  • 始终使用同步原语或 channel 来建立 Happens-Before 关系。
  • 避免依赖 goroutine 调度顺序或 time.Sleep 来同步数据。
  • 使用 go run -race 检测 data race，确保代码符合内存模型。
← 上一章 📖 返回目录 下一章 →