go Mutex （互斥锁）和RWMutex（读写锁）

golang中sync包实现了两种锁Mutex （互斥锁）和RWMutex（读写锁），其中RWMutex是基于Mutex实现的，只读锁的实现使用类似引用计数器的功能．

type Mutex

func (m *Mutex) Lock()

func (m *Mutex) Unlock()

type RWMutex

func (rw *RWMutex) Lock()

func (rw *RWMutex) RLock()

func (rw *RWMutex) RLocker() Locker

func (rw *RWMutex) RUnlock()

func (rw *RWMutex) Unlock()

其中Mutex为互斥锁，Lock()加锁，Unlock()解锁，使用Lock()加锁后，便不能再次对其进行加锁，直到利用Unlock()解锁对其解锁后，才能再次加锁．适用于读写不确定场景，即读写次数没有明显的区别，并且只允许只有一个读或者写的场景，所以该锁叶叫做全局锁．

func (m *Mutex) Unlock()用于解锁m，如果在使用Unlock()前未加锁，就会引起一个运行错误．

已经锁定的Mutex并不与特定的goroutine相关联，这样可以利用一个goroutine对其加锁，再利用其他goroutine对其解锁．

正常运行例子：

[html] view plain copy

package main
import (
"fmt"
"sync"
)
func main() {
var l *sync.Mutex
l = new(sync.Mutex)
l.Lock()
defer l.Unlock()
fmt.Println("1")
}
结果输出：１

当Unlock()在Lock()之前使用时，便会报错

[html] view plain copy

package main
import (
"fmt"
"sync"
)
func main() {
var l *sync.Mutex
l = new(sync.Mutex)
l.Unlock()
fmt.Println("1")
l.Lock()
}
运行结果： panic: sync: unlock of unlocked mutex

当在解锁之前再次进行加锁，便会死锁状态

[html] view plain copy

package main
import (
"fmt"
"sync"
)
func main() {
var l *sync.Mutex
l = new(sync.Mutex)
l.Lock()
fmt.Println("1")
l.Lock()
}
运行结果： 1
fatal error: all goroutines are asleep - deadlock!

RWMutex是一个读写锁，该锁可以加多个读锁或者一个写锁，其经常用于读次数远远多于写次数的场景．

func (rw *RWMutex) Lock()　　写锁，如果在添加写锁之前已经有其他的读锁和写锁，则lock就会阻塞直到该锁可用，为确保该锁最终可用，已阻塞的 Lock 调用会从获得的锁中排除新的读取器，即写锁权限高于读锁，有写锁时优先进行写锁定
func (rw *RWMutex) Unlock()　写锁解锁，如果没有进行写锁定，则就会引起一个运行时错误．

[html] view plain copy

package main
import (
"fmt"
"sync"
)
func main() {
var l *sync.RWMutex
l = new(sync.RWMutex)
l.Unlock()
fmt.Println("1")
l.Lock()
}
运行结果：panic: sync: unlock of unlocked mutex

func (rw *RWMutex) RLock() 读锁，当有写锁时，无法加载读锁，当只有读锁或者没有锁时，可以加载读锁，读锁可以加载多个，所以适用于＂读多写少＂的场景

func (rw *RWMutex)RUnlock()　读锁解锁，RUnlock 撤销单次 RLock 调用，它对于其它同时存在的读取器则没有效果。若 rw 并没有为读取而锁定，调用 RUnlock 就会引发一个运行时错误(注：这种说法在go1.3版本中是不对的，例如下面这个例子)。

[html] view plain copy

package main
import (
"fmt"
"sync"
)
func main() {
var l *sync.RWMutex
l = new(sync.RWMutex)
l.RUnlock()　　　　//１个RUnLock
fmt.Println("1")
l.RLock()
}
运行结果：１
但是程序中先尝试解锁读锁，然后才加读锁，但是没有报错，并且能够正常输出．

分析：go1.3版本中出现这种情况的原因分析，通过阅读源码可以很清晰的得到结果

[html] view plain copy

func (rw *RWMutex) RUnlock() {
if raceenabled {
_ = rw.w.state
raceReleaseMerge(unsafe.Pointer(&rw.writerSem))
raceDisable()
}<span style="color:#FF0000;">
if atomic.AddInt32(&rw.readerCount, -1) < 0 {　//readercounter初始值为０,调用RUnLock之后变为-1，继续往下执行
// A writer is pending.
if atomic.AddInt32(&rw.readerWait, -1) == 0 {　//此时readerwaiter变为１，1-1之后变为０,可以继续以后的操作．</span>
// The last reader unblocks the writer.
runtime_Semrelease(&rw.writerSem)
}
}
if raceenabled {
raceEnable()
}
}

当RUnlock多于RLock多个时，便会报错，进入死锁．实例如下：

[html] view plain copy

package main
import (
"fmt"
"sync"
)
type s struct {
readerCount int32
}
func main() {
l := new(sync.RWMutex)
l.RUnlock()
l.RUnlock()　　　　　　　　//此处出现死锁
fmt.Println("1")
l.RLock()
}
运行结果：
1
fatal error: all goroutines are asleep - deadlock!

总结：

所以在go1.3版本中，运行过程中允许RUnLock早于RLock一个，也只能早于１个（注：虽然代码允许，但是强烈不推荐使用），并且在早于之后必须利用RLock进行加锁才可以继续使用．

go Mutex （互斥锁）和RWMutex（读写锁）相关推荐

Linux系统编程----16（线程同步，互斥量 mutex,互斥锁的相关函数，死锁，读写锁）
同步概念所谓同步,即同时起步,协调一致.不同的对象,对"同步"的理解方式略有不同.如,设备同步,是指在两个设备之间规定一个共同的时间参考:数据库同步,是指让两个或多个数据库内容 ...
golang mutex互斥锁分析
互斥锁:没有读锁写锁之分,同一时刻,只能有一个gorutine获取一把锁数据结构设计: type Mutex struct {state int32 // 将一个32位整数拆分为当前阻塞的goro ...
golang sync.Mutex 互斥锁使用实例
实例: var mutex sync.Mutex //互斥锁 func printer(str string){mutex.Lock() //加锁defer mutex.Unlock() //解锁fo ...
Linux系统编程：使用mutex互斥锁和条件变量实现多个生成者和消费者模型
实现代码如题,使用mutex互斥锁和条件变量实现多个生成者和消费者模型. 直接上代码,需要线程中的互斥锁和条件变量的相关知识进行支撑.这里就不细说了呀,代码中有一定的注释. #include < ...
Java中的共享锁和排他锁（以读写锁ReentrantReadWriteLock为例）
重要声明:本人之前对java中的读写锁也不是非常了解,用的也不是很多,尤其在读写锁的策略原理一块没有深究过,本篇文章是在学习[玩转Java并发工具,精通JUC,成为并发多面手]课程后写的,故文章类型选 ...
Go sync.Mutex互斥锁的学习
1. 前言 1.1 基础回顾原子操作:指那些不能够被打断的操作被称为原子操作,当有一个CPU在访问这块内容addr时,其他CPU就不能访问. CAS:比较及交换,其实也属于原子操作,但它是非阻塞的, ...
MySQL mutex互斥锁
在事务机制中,锁机制是为了保证高并发,数据一致性的重要实现方式.MySQL除了Innodb引擎层面的行锁,还有latch锁.latch锁的作用资源协调处理.包含表句柄,线程,cpu线程,内存池等.其保 ...
并发编程-19AQS同步组件之重入锁ReentrantLock、读写锁ReentrantReadWriteLock、Condition
文章目录 J.U.C脑图 ReentrantLock概述 ReentrantLock 常用方法 synchronized 和 ReentrantLock的比较 ReentrantLock示例读写锁R ...
linux之mutex(互斥锁)
在Posix Thread中定义有一套专门用于线程同步的mutex函数 1．创建和销毁有两种方法创建互斥锁,静态方式和动态方式.POSIX定义了一个宏PTHREAD_MUTEX_INITIALIZ ...
Linux系统编程37：多线程之什么是临界区和临界资源以及如何使用mutex互斥锁
文章目录 (1)临界区,临界资源和原子性问题 (2)互斥量(锁) A:互斥锁 B:锁的作用 C:互斥锁实现的原理 (3)可重入函数和线程安全 A:可重入函数和线程安全 B:常见的线程安全和不安全情况 ...

go Mutex （互斥锁）和RWMutex（读写锁）

go Mutex （互斥锁）和RWMutex（读写锁）相关推荐

最新文章

热门文章