01
写在前面
过去 Web 开发的工作比较少涉及到并发的问题,每个用户请求在独立的 线程 里面进行,偶尔涉及到异步任务但是线程间数据同步模型非常简单,因此并未深入探究过并发这一块。最近在写游戏相关的服务端代码时发现数据的并发同步场景非常多,因此花了一点时间来探索。
本文通过一个例子来简单引出 Golang 中的数据并发同步问题,并通过简单加锁的方式来避免数据竞争问题。
02
从一个例子看 线程安全 与数据竞争问题
一个非常原始的数据竞争问题
下面的代码模拟了为一个用户(Person)发放金币(Money)的代码,其中金币发放与读取分别再不同的线程里完成(读取在主线程,发放在一个子线程)。
运行上面的代码:
通过运行代码并查看输出可以确认:① 代码可以正常运行(并没有因为多个线程读写同一个变量而崩溃),② 由于数据没有同步最后输出的数据 Money: 100 与预期的数据1100存在误差,③ 通过 go run -race main.go 添加 -race 标识可以发现 数据竞争 问题。
通过加锁的方式优化有数据竞争的代码
下面的代码里给 Person 添加了一个 读写锁 mutext sync.RWMutex,并通过添加两个方法 GetMoney 和 AddMoney 来达到读取和修改 Money 的数值的目的。
运行上面的代码:
# 添加 -race 后检测竞争状态,此时已经看不到 race 的告警 go run -race main.go # Money: 100
通过运行代码并查看输出可以确认:① 代码可以正常运行(并没有因为多个线程读写同一个变量而崩溃),② 由于数据没有同步最后输出的数据 Money: 100 与预期的数据1100存在误差 ③ 已经没有了 数据竞争 问题。
示例代码的进一步阐释
上面的代码逻辑,加锁前 与 加锁后最大的区别是:加锁前 存在数据竞争问题,加锁后不存在数据竞争问题。而无论是否加锁,代码均可以正常运行,且最终同步的数据与预期的数据均存在偏差。
之所以强调代码可以正常运行,是因为代码一定概率是会崩溃的,只是一般类型(map 类型除外)不那么容易出现崩溃的情况(任何类型变量的使用都可能会出现这个问题,详见《 谈谈go语言编程的并发安全》 和 《 benign-data-races-what-could-possibly-go-wrong 》 的讨论)。
由于运行时序的存在,读取得到的数据与预期的数据存在偏差可以这样解释:虽然期望里给用户加了 1000 金钱,但是如果读取是在 加 1000 金钱 之前发生的,也确实是感知不到 加 1000 金钱 这个事件的。
03
小结
本文简单介绍了 Golang 中数据的并发同步问题,并通过加锁的方式避免了 数据竞争 问题。加锁在各个语言中都是一种常见的方式,理解起来是比较容易的,因此本文并没有对加锁机制进行进一步的阐述。
不过,数据的并发同步是一个涉及很广泛的问题,接下来需要继续总结。
04
参考
- 谈谈go语言编程的并发安全 比较透彻地介绍了 Golang 中并发安全的问题(加锁场景)
- benign-data-races-what-could-possibly-go-wrong Intel 工程师讲数据竞争问题
- sync – The Go Programming Language Golang 官方提供的 sync 包的文档
- The Go Memory Model – The Go Programming Language Golang 中内存模型的建议(Advice)
原文:
本文作者:敬维,原创授权发布