sync包——读写锁
官网文档对sync包的介绍:
Package sync provides basic synchronization primitives such as mutual exclusion locks. Other than the Once and WaitGroup types, most are intended for use by low-level library routines. Higher-level synchronization is better done via channels and communication.
sync是synchronization同步这个词的缩写,所以也会叫做同步包。这里提供了基本同步的操作,比如互斥锁等等。这里除了Once和WaitGroup类型之外,大多数类型都是供低级库例程使用的。更高级别的同步最好通过channel通道和communication通信来完成
一、RWMutex(读写锁)
通过对互斥锁的学习,我们已经知道了锁的概念以及用途。主要是用于处理并发中的临界资源问题。
Go语言包中的 sync 包提供了两种锁类型:sync.Mutex 和 sync.RWMutex。其中RWMutex是基于Mutex实现的,只读锁的实现使用类似引用计数器的功能。
RWMutex是读/写互斥锁。锁可以由任意数量的读取器或单个编写器持有。RWMutex的零值是未锁定的mutex。
如果一个goroutine持有一个rRWMutex进行读取,而另一个goroutine可能调用lock,那么在释放初始读取锁之前,任何goroutine都不应该期望能够获取读取锁。特别是,这禁止递归读取锁定。这是为了确保锁最终可用;被阻止的锁调用会将新的读卡器排除在获取锁之外。
我们怎么理解读写锁呢?当有一个 goroutine 获得写锁定,其它无论是读锁定还是写锁定都将阻塞直到写解锁;当有一个 goroutine 获得读锁定,其它读锁定仍然可以继续;当有一个或任意多个读锁定,写锁定将等待所有读锁定解锁之后才能够进行写锁定。所以说这里的读锁定(RLock)目的其实是告诉写锁定:有很多人正在读取数据,你给我站一边去,等它们读(读解锁)完你再来写(写锁定)。我们可以将其总结为如下三条:
同时只能有一个 goroutine 能够获得写锁定。
同时可以有任意多个 gorouinte 获得读锁定。
同时只能存在写锁定或读锁定(读和写互斥)。
所以,RWMutex这个读写锁,该锁可以加多个读锁或者一个写锁,其经常用于读次数远远多于写次数的场景。
读写锁的写锁只能锁定一次,解锁前不能多次锁定,读锁可以多次,但读解锁次数最多只能比读锁次数多一次,一般情况下我们不建议读解锁次数多余读锁次数。
基本遵循两大原则:
1、可以随便读,多个goroutine同时读。
2、写的时候,啥也不能干。不能读也不能写。
读写锁即是针对于读写操作的互斥锁。它与普通的互斥锁最大的不同就是,它可以分别针对读操作和写操作进行锁定和解锁操作。读写锁遵循的访问控制规则与互斥锁有所不同。在读写锁管辖的范围内,它允许任意个读操作的同时进行。但是在同一时刻,它只允许有一个写操作在进行。
并且在某一个写操作被进行的过程中,读操作的进行也是不被允许的。也就是说读写锁控制下的多个写操作之间都是互斥的,并且写操作与读操作之间也都是互斥的。但是,多个读操作之间却不存在互斥关系。
二、常用方法
2.1、RLock()方法
func (rw *RWMutex) RLock()
读锁,当有写锁时,无法加载读锁,当只有读锁或者没有锁时,可以加载读锁,读锁可以加载多个,所以适用于“读多写少”的场景。
2.2、RUnlock()方法
func (rw *RWMutex) RUnlock()
读锁解锁,RUnlock 撤销单次RLock调用,它对于其它同时存在的读取器则没有效果。若rw并没有为读取而锁定,调用RUnlock就会引发一个运行时错误。
2.3、Lock()方法:
func (rw *RWMutex) Lock()
写锁,如果在添加写锁之前已经有其他的读锁和写锁,则Lock就会阻塞直到该锁可用,为确保该锁最终可用,已阻塞的Lock调用会从获得的锁中排除新的读取锁,即写锁权限高于读锁,有写锁时优先进行写锁定。
2.4、Unlock()方法
func (rw *RWMutex) Unlock()
写锁解锁,如果没有进行写锁定,则就会引起一个运行时错误。
三、示例代码:
示例代码:
package main import ("fmt""sync""time" ) var rwMutex *sync.RWMutex var wg *sync.WaitGroup func main() {rwMutex = new(sync.RWMutex)wg = new (sync.WaitGroup) //wg.Add(2)//多个同时读取//go readData(1)//go readData(2) wg.Add(3)go writeData(1)go readData(2)go writeData(3) wg.Wait()fmt.Println("main..over...") } func writeData(i int){defer wg.Done()fmt.Println(i,"开始写:write start。。")rwMutex.Lock()//写操作上锁fmt.Println(i,"正在写:writing。。。。")time.Sleep(3*time.Second)rwMutex.Unlock()fmt.Println(i,"写结束:write over。。") } func readData(i int) {defer wg.Done() fmt.Println(i, "开始读:read start。。") rwMutex.RLock() //读操作上锁fmt.Println(i,"正在读取数据:reading。。。")time.Sleep(3*time.Second)rwMutex.RUnlock() //读操作解锁fmt.Println(i,"读结束:read over。。。") }
运行结果:
GOROOT=/usr/local/go #gosetup GOPATH=/Users/ruby/go #gosetup /usr/local/go/bin/go build -i -o /private/var/folders/kt/nlhsnpgn6lgd_q16f8j83sbh0000gn/T/___go_build_demo07_rwmutex_go /Users/ruby/go/src/l_goroutine/demo07_rwmutex.go #gosetup /private/var/folders/kt/nlhsnpgn6lgd_q16f8j83sbh0000gn/T/___go_build_demo07_rwmutex_go #gosetup 3 开始写:write start 3 正在写:writing 2 开始读:read start 1 开始写:write start 3 写结束:write over 2 正在读:reading 2 读结束:read over 1 正在写:writing 1 写结束:write over main..over... Process finished with exit code 0
最后概括:
读锁不能阻塞读锁
读锁需要阻塞写锁,直到所有读锁都释放
写锁需要阻塞读锁,直到所有写锁都释放
写锁需要阻塞写锁
sync包——读写锁相关推荐
- GO语言基础进阶教程:sync包——读写锁
官网文档对sync包的介绍: Package sync provides basic synchronization primitives such as mutual exclusion locks ...
- goroutine sync.RWMutex读写锁RLock的使用
- go语言基础-----18-----协程安全、互斥锁、读写锁、匿名锁、sync.Once
1 线(协)程安全-互斥锁 竞态检查工具是基于运行时代码检查,而不是通过代码静态分析来完成的,可以添加-race 来执行竞态检测.但是对于那些没 有机会运行到的代码逻辑中如果存在安全隐患,即使加了-r ...
- go 分段锁ConcurrentMap,map+读写锁,sync.map的效率测试
分段锁ConcurrentMap的实现请参考笔者的另外一篇博客: go 分段锁ConcurrentMap的实现源码 效率测试结论: 1. go自带的map不是多协程安全的 2. 分段锁Concurre ...
- go语言 rlock() defer runlock()_Go并发编程之美-读写锁
一.前言 go语言类似Java JUC包也提供了一些列用于多线程之间进行同步的措施,比如低级的同步措施有 锁.CAS.原子变量操作类.相比Java来说go提供了独特的基于通道的同步措施.本节我们先来看 ...
- Go并发编程之美-读写锁
一.前言 go语言类似Java JUC包也提供了一些列用于多线程之间进行同步的措施,比如低级的同步措施有 锁.CAS.原子变量操作类.相比Java来说go提供了独特的基于通道的同步措施.本节我们先来看 ...
- 4.12 并发技术:sync包同步调度综合案例
同步调度概述 Go语言的并发中,当使用go关键字开辟若干新的协程时,如果不加干涉,它们会完全并发地得到执行: 而所谓调度,就是在并发的局部植入一些串行和同步的操作,让某些协程有逻辑上的先后关系: 执行 ...
- Java 读写锁实现原理
2019独角兽企业重金招聘Python工程师标准>>> 最近做的一个小项目中有这样的需求:整个项目有一份config.json保存着项目的一些配置,是存储在本地文件的一个资源,并且应 ...
- Java之读写锁ReadWriteLock实现
一.为什么需要读写锁? 与传统锁不同的是读写锁的规则是可以共享读,但只能一个写,总结起来为:读读不互斥,读写互斥,写写互斥,而一般的独占锁是:读读互斥,读写互斥,写写互斥,而场景中往往读远远大于写,读 ...
最新文章
- 冠军奖3万元!CSDN×易观算法大赛开赛啦
- MySQL Proxy 读写分离(实战总结)
- 通信网络基础期末复习-第一章和第二章-概论和端到端的传输协议
- JavaSE(十一)——多线程
- 一作发14篇SCI,累计IF60,博士前两年,他也曾走过弯路
- 使用Prometheus监控Flink
- Python基础教程(020)--集成开发环境IDE简介--Pycharm
- html5中box-shadow,CSS阴影效果(Box-shadow)用法趣味讲解
- JavaEE高级框架学习笔记(八)Struts高级ActionForm
- fn键台式计算机在哪,fn键在哪?小鱼教您fn键使用方法
- 免费的DDoS防火墙有哪些
- 51单片机蜂鸣器实验
- [转]内向的人如何建立人际网络
- win7 ftp安装搭建,并且上传图片到ftp文件夹下,使用nginx访问下载图片
- asp.net面试常见试题
- innerHtml() 与html( )的区别
- Ubuntu入门,Ubuntu基本软件,Ubuntu起始配置
- linux 页缓存 块缓存,页缓存和块缓存
- 中国商用显示行业“十四五”前景规划及发展方向分析报告2022-2027年版
- 第四章 :JavaEE项目之“谷粒商城” ----快速开发
热门文章
- 使用PaddleDetection自带脚本将自制labelme数据集转为coco格式
- 外汇天眼:FXOpen宣布降低40%点差,对交易者来说是利好么?
- CAN Interaction Layer (谈谈我对交互层的理解)
- ASP.NET学习之Repeater
- Tableau-帕累托图制作
- 康佳P200投影仪咋样?和哈趣H1哪个更好,对比两款投影仪参数区别
- 爬虫 google maps接口分析
- 积极向上的佳句(2)
- Leetcode算法题每日一练
- nodejs+vue+mysql的高校二手跳蚤市场交易网站express