golang并发锁使用详解
来源：脚本之家
时间：2023-02-25 08:54:39 107浏览 收藏
学习知识要善于思考，思考，再思考！今天golang学习网小编就给大家带来《golang并发锁使用详解》，以下内容主要包含并发锁等知识点，如果你正在学习或准备学习Golang，就都不要错过本文啦~让我们一起来看看吧，能帮助到你就更好了！
如果程序用到的数据是多个groutine之间的交互过程中产生的，那么使用上文提到的channel就可以解决了。
如果我们的使用多个groutine访问和修改同一个数据，就需要考虑在并发环境下数据一致性的问题，即线程安全问题。
以存钱为例说明一下问题。假设我们发起一个众筹项目，并发1000个用户的向一个银行银行账号存钱。
package main
import (
"fmt"
"sync"
)
var wg sync.WaitGroup
func Save(income int, balance *int) {
defer wg.Done()
*balance = *balance + income
}
func main() {
balance := 0
//wg.Add(1000)
for s := 0; s 运行结果，正常应该是收到1000元。代码中使用了&符号传递余额变量地址，但是怎么运行结果都不对。这个问题的原因并不是值传递还是引用传递的问题。而是多groutine并发访问变量的时候，变量值因为没有锁定被多个groutine反复修改所致。比如第一个groutine运行的时候获取的变量为0，运算之后变量值被回写为1。但是由于的groutine启动顺序是并不一致，即第200个groutine启动获取变量值的时候，第20个groutine刚好运算结束把结果20写回了变量。那么第200个groutine就拿到变量值20进行了计算了。这就是导致数据丢失的原因。
% go run main.go 当前账户余额： 947 % go run main.go 当前账户余额： 938 % go run main.go 当前账户余额： 948
解决的办法，就是操作变量的时候加个锁。每次只允许一个groutine读写这个变量，读写完成后释放
互斥锁 sync.Mutex
使用sync.Mutex对象，对数据进行加解锁操作
package main
import (
"fmt"
"sync"
)
var wg sync.WaitGroup
// 声明一个sync.Mutex 类型
var lk sync.Mutex
func Save(income int, balance *int) {
defer wg.Done()
// 操作前给先加锁
lk.Lock()
*balance = *balance + income
// 操作后解锁
lk.Unlock()
}
func main() {
balance := 0
//wg.Add(1000)
for s := 0; s 运行结果，始终与预期一致了
% go run main.go 当前账户余额： 1000 % go run main.go 当前账户余额： 1000 % go run main.go 当前账户余额： 1000
读写锁 sync.RWMutex
互斥锁虽然解决了数据一致性的问题，但是在运行过程中进程无论是读写要等待解锁，如果是读多写少的场景，那么读groutine就进行了很多无谓等待。读写锁的应对此类需求就非常合适。读写锁的工作原理是当变量要被变更时，无论读写都会block。当数据没有变更时，只读操作允许并发进行。
package main
import (
"fmt"
"sync"
"time"
)
var wg sync.WaitGroup
// 声明一个读写锁sync.RWMutex类型
var lk sync.RWMutex
func Save(thr int, income int, balance *int) {
defer wg.Done()
// 操作前给先加写锁
lk.Lock()
fmt.Printf("write-groutine-添加写锁\n", thr)
*balance = *balance + income
time.Sleep(time.Millisecond * 1)
fmt.Printf("write-groutine-解除写锁\n", thr)
// 解除写锁
lk.Unlock()
}
func Show(thr int, balance *int) {
defer wg.Done()
//如果使用互斥锁，即使函数是只读操作，也要等待解锁才可读取
// 读取前加读锁
lk.RLock()
fmt.Printf("read-groutine-开始读取数据\n", thr)
time.Sleep(time.Millisecond * 1)
fmt.Printf("read-groutine-完成读取数据\n", thr)
// 解除读锁
lk.RUnlock()
}
func main() {
balance := 0
StartTime := time.Now()
// 写操作3次
for s := 0; s 运行结果，加解锁写操作成对出现。说明在写操作时只有一个groutine在运行，其他groutine被锁住了。读操作的加解锁标记有差距且启动顺序混乱，说明读的时候是多个groutine并发运行没有锁限制。
% go run main.go write-groutine-添加写锁 write-groutine-解除写锁 read-groutine-开始读取数据 # 1号读groutine开始读数据 read-groutine-开始读取数据 read-groutine-开始读取数据 read-groutine-开始读取数据 read-groutine-开始读取数据 read-groutine-开始读取数据 read-groutine-开始读取数据 read-groutine-开始读取数据 read-groutine-开始读取数据 read-groutine-开始读取数据 read-groutine-完成读取数据 read-groutine-完成读取数据 read-groutine-完成读取数据 read-groutine-完成读取数据 read-groutine-完成读取数据 # # 1号读groutine完成读数据，耗时1ms read-groutine-完成读取数据 read-groutine-完成读取数据 read-groutine-完成读取数据 read-groutine-完成读取数据 read-groutine-完成读取数据 write-groutine-添加写锁 # 0号写groutine要等到其他写锁释放，才能添加自己的写锁 write-groutine-解除写锁 # 0号写groutine完成写操作耗时1ms，写期间其他groutine挂起 write-groutine-添加写锁 write-groutine-解除写锁 最终账户余额： 3 程序运行耗时: 45.2403ms
今天带大家了解了并发锁的相关知识，希望对你有所帮助；关于Golang的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~
-
505 收藏
-
502 收藏
-
501 收藏
-
501 收藏
-
501 收藏
-
427 收藏
-
250 收藏
-
475 收藏
-
389 收藏
-
314 收藏
-
160 收藏
-
419 收藏
-
249 收藏
-
285 收藏
-
145 收藏
-
338 收藏
-
330 收藏
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案，代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景，打造一站式知识长龙服务，适合有JS基础的同学学习。
- 立即学习 542次学习
-
- GO语言核心编程课程
- 本课程采用真实案例，全面具体可落地，从理论到实践，一步一步将GO核心编程技术、编程思想、底层实现融会贯通，使学习者贴近时代脉搏，做IT互联网时代的弄潮儿。
- 立即学习 508次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信：Le-studyg；在课程中，我们将首先介绍MySQL8的新特性，包括性能优化、安全增强、新数据类型等，帮助学生快速熟悉MySQL8的最新功能。接着，我们将深入解析MySQL的网络通信机制，包括协议、连接管理、数据传输等，让
- 立即学习 497次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 立即学习 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网，分为导航，轮播，关于我们，成功案例，服务流程，团队介绍，数据部分，公司动态，底部信息等内容区块。网站整体采用CSSGrid布局，支持响应式，有流畅过渡和展现动画。
- 立即学习 484次学习
-
- 暴躁的含羞草
- 这篇技术贴出现的刚刚好，很详细，赞 👍👍，码起来，关注作者大大了！希望作者大大能多写Golang相关的文章。
- 2023-02-27 08:04:37