详解Go内存模型

论坛 期权论坛 脚本     
niminba   2021-5-23 03:01   1403   0

介绍

Go 内存模型规定了一些条件,在这些条件下,在一个 goroutine 中读取变量返回的值能够确保是另一个 goroutine 中对该变量写入的值。【翻译这篇文章花费了我 3 个半小时 】

Happens Before(在…之前发生)

在一个 goroutine 中,读操作和写操作必须表现地就好像它们是按照程序中指定的顺序执行的。这是因为,在一个 goroutine 中编译器和处理器可能重新安排读和写操作的执行顺序(只要这种乱序执行不改变这个 goroutine 中在语言规范中定义的行为)。

因为乱序执行的存在,一个 goroutine 观察到的执行顺序可能与另一个 goroutine 观察到的执行顺序不同。 比如,如果一个 goroutine 执行a = 1; b = 2;,另一个 goroutine 可能观察到 b 的值在 a 之前更新。

为了规定读取和写入的必要条件,我们定义了 happens before (在…之前发生),一个在 Go 程序中执行内存操作的部分顺序。如果事件 e1 发生在事件 e2 之前,那么我们说 e2 发生在 e1 之后。同样,如果 e1 不在 e2 之前发生也不在 e2 之后发生,那么我们说 e1 和 e2 同时发生。

在一个单独的 goroutine 中,happens-before 顺序就是在程序中的顺序。

一个对变量 v 的 读操作 r 可以被允许观察到一个对 v 的写操作 w,如果下列条件同时满足:

r 不在 w 之前发生在 w 之后,r 之前,没有其他对 v 的写入操作 w' 发生。

为了确保一个对变量 v 的读操作 r 观察到一个对 v 的 写操作 w,必须确保 w 是唯一的 r 允许的写操作。就是说下列条件必须同时满足:

w 在 r 之前发生任何其他对共享的变量 v 的写操作发生在 w 之前或 r 之后。

这两个条件比前面两个条件要严格,它要求不能有另外的写操作与 w 或 r 同时发生。

在一个单独的 goroutine 中,没有并发存在,所以这两种定义是等价的:一个读操作 r 观察到的是最近对 v 的写入操作 w 。当多个 goroutine 访问一个共享的变量 v 时,它们必须使用同步的事件来建立 happens-before 条件来确保读操作观察到预期的写操作。

在内存模型中,使用零值初始化一个变量的 v 的行为和写操作的行为一样。

读取和写入超过单个机器字【32 位或 64 位】大小的值的行为和多个无序地操作单个机器字的行为一样。

同步

初始化

程序初始化操作在一个单独的 goroutine 中运行,但是这个 goroutine 可能创建其他并发执行的 goroutines。

如果包 p 导入了包 q,那么 q 的 init 函数执行完成发生在 p 的任何 init 函数执行之前。

函数 main.main【也就是 main 函数】 的执行发生在所有的 init 函数完成之后。

Goroutine 创建

启动一个新的 goroutine 的 go 语句的执行在这个 goroutine 开始执行前发生。

比如,在这个程序中:

var a string

func f() {
 print(a) // 后
}

func hello() {
 a = "hello, world"
 go f() // 先
}

调用 hello 函数将会在之后的某个事件点打印出 “hello, world”。【因为 a = “hello, world” 语句在 go f() 语句之前执行,而 goroutine 执行的函数 f 在 go f() 语句之后执行,a 的值已经初始化了 】

Goroutine 销毁

goroutine 的退出不保证发生在程序中的任何事件之前。比如,在这个程序中:

var a string

func hello() {
 go func() { a = "hello" }()
 print(a)
}

a 的赋值之后没有跟随任何同步事件,所以不能保证其他的 goroutine 能够观察到赋值操作。事实上,一个激进的编译器可能删除掉整个 go 语句。

如果在一个 goroutine 中赋值的效果必须被另一个 goroutine 观察到,那么使用锁或者管道通信这样的同步机制来建立一个相对的顺序。

管道通信

管道通信是在 goroutine 间同步的主要方法。一个管道的发送操作匹配【对应】一个管道的接收操作(通常在另一个 goroutine 中)。

一个在有缓冲的管道上的发送操作在相应的接收操作完成之前发生。

这个程序:

var c = make(chan int, 10) // 有缓冲的管道
var a string

func f() {
 a = "hello, world"
 c <- 0 // 发送操作,先
}

func main() {
 go f()
 <-c // 接收操作,后
 print(a)
}

能够确保输出 “hello, world”。因为对 a 的赋值操作在发送操作前完成,而接收操作在发送操作之后完成。

关闭一个管道发生在从管道接收一个零值之前。

在之前的例子中,将 c <- 0 语句替换成 close(c) 效果是一样d能确保它观察到了 g.msg 的初始值。

在所有这些例子中,解决方法都是相同的:使用显示地同步。

到此这篇关于Go 内存模型的文章就介绍到这了,更多相关Go 内存模型内容请搜索社区以前的文章或继续浏览下面的相关文章希望大家以后多多支持社区!

分享到 :
0 人收藏
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

积分:1060120
帖子:212021
精华:0
期权论坛 期权论坛
发布
内容

下载期权论坛手机APP