个人中心
gpt4 book ai didi

Go语言并发编程之互斥锁Mutex和读写锁RWMutex

转载 作者：qq735679552 更新时间：2022-09-27 22:32:09 26 4
gpt4 key购买 nike

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章Go语言并发编程之互斥锁Mutex和读写锁RWMutex由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

在并发编程中，多个Goroutine访问同一块内存资源时可能会出现竞态条件，我们需要在临界区中使用适当的同步操作来以避免竞态条件。Go 语言中提供了很多同步工具，本文将介绍互斥锁Mutex和读写锁RWMutex的使用方法.

1、互斥锁Mutex

1、Mutex介绍

Go 语言的同步工具主要由 sync 包提供，互斥锁 (Mutex) 与读写锁 (RWMutex) 就是sync 包中的方法.

互斥锁可以用来保护一个临界区，保证同一时刻只有一个 goroutine 处于该临界区内。主要包括锁定（Lock方法）和解锁（Unlock方法）两个操作，首先对进入临界区的goroutine进行锁定，离开时进行解锁.

使用互斥锁 (Mutex)时要注意以下几点:

  • 不要重复锁定互斥锁，否则会阻塞，也可能会导致死锁（deadlock）；
  • 要对互斥锁进行解锁，这也是为了避免重复锁定；
  • 不要对未锁定或者已解锁的互斥锁解锁；
  • 不要在多个函数之间直接传递互斥锁，sync.Mutex类型属于值类型，将它传给一个函数时，会产生一个副本，在函数中对锁的操作不会影响原锁

总之，一个互斥锁只用来保护一个临界区，加锁后记得解锁，对于每一个锁定操作，都要有且只有一个对应的解锁操作，也就是加锁和解锁要成对出现，最保险的做法时使用 defer语句 解锁.

2、Mutex使用实例

下面的代码模拟取钱和存钱操作:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
package main
 
import (
  "flag"
  "fmt"
  "sync"
)
 
var (
     mutex   sync .Mutex
     balance int
     protecting uint  // 是否加锁
     sign = make (chan struct{}, 10) // 通道，用于等待所有goroutine
)
 
// 存钱
func deposit(value int) {
     defer func() {
         sign <- struct{}{}
     }()
 
     if protecting == 1 {
         mutex.Lock()
         defer mutex.Unlock()
     }
 
     fmt .Printf( "余额: %d\n" , balance)
     balance += value
     fmt .Printf( "存 %d 后的余额: %d\n" , value, balance)
     fmt .Println()
 
}
 
// 取钱
func withdraw(value int) {
     defer func() {
         sign <- struct{}{}
     }()
    
     if protecting == 1 {
         mutex.Lock()
         defer mutex.Unlock()
     }
 
     fmt .Printf( "余额: %d\n" , balance)
     balance -= value
     fmt .Printf( "取 %d 后的余额: %d\n" , value, balance)
     fmt .Println()
 
}
 
func main() {
    
     for i:=0; i < 5; i++ {
         go withdraw(500) // 取500
         go deposit(500)  // 存500
     }
 
     for i := 0; i < 10; i++ {
   <-sign
  }
     fmt .Printf( "当前余额: %d\n" , balance)
}
 
func init() {
     balance = 1000 // 初始账户余额为1000
     flag.UintVar(&protecting, "protecting" , 0, "是否加锁，0表示不加锁，1表示加锁" )
}

上面的代码中，使用了通道来让主 goroutine 等待其他 goroutine 运行结束，每个子goroutine在运行结束之前向通道发送一个元素，主 goroutine 在最后从这个通道接收元素，接收次数与子goroutine个数相同。接收完后就会退出主goroutine.

代码使用协程实现多次（5次）对一个账户进行存钱和取钱的操作，先来看不加锁的情况:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
余额: 1000
存 500 后的余额: 1500
 
余额: 1000
取 500 后的余额: 1000
 
余额: 1000
存 500 后的余额: 1500
 
余额: 1000
取 500 后的余额: 1000
 
余额: 1000
存 500 后的余额: 1500
 
余额: 1000
取 500 后的余额: 1000
 
余额: 1000
取 500 后的余额: 500
 
余额: 1000
存 500 后的余额: 1000
 
余额: 1000
取 500 后的余额: 500
 
余额: 1000
存 500 后的余额: 1000
 
当前余额: 1000

可以看到出现了混乱，比如第二次1000的余额取500后还是1000，这种对同一资源的竞争出现了竞态条件(Race Condition).

下面来看加锁的执行结果:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
余额: 1000
取 500 后的余额: 500
 
余额: 500
存 500 后的余额: 1000
 
余额: 1000
取 500 后的余额: 500
 
余额: 500
存 500 后的余额: 1000
 
余额: 1000
取 500 后的余额: 500
 
余额: 500
存 500 后的余额: 1000
 
余额: 1000
存 500 后的余额: 1500
 
余额: 1500
取 500 后的余额: 1000
 
余额: 1000
取 500 后的余额: 500
 
余额: 500
存 500 后的余额: 1000
 
当前余额: 1000

加锁后就正常了.

下面介绍更细化的互斥锁：读/写互斥锁RWMutex.

2、读写锁RWMutex

1、RWMutex介绍

读/写互斥锁RWMutex包含了读锁和写锁，分别对共享资源的“读操作”和“写操作”进行保护。sync.RWMutex类型中的Lock方法和Unlock方法分别用于对写锁进行锁定和解锁，而它的RLock方法和RUnlock方法则分别用于对读锁进行锁定和解锁.

有了互斥锁Mutex，为什么还需要读写锁呢？因为在很多并发操作中，并发读取占比很大，写操作相对较少，读写锁可以并发读取，这样可以提供服务性能。读写锁具有以下特征:

  。

读写锁 读锁 写锁
读锁 Yes No
写锁 No No

  。

也就是说， 。

  • 如果某个共享资源受到读锁和写锁保护时，其它goroutine不能进行写操作。换句话说就是读写操作和写写操作不能并行执行，也就是读写互斥；
  • 受读锁保护时，可以同时进行多个读操作。

在使用读写锁时，还需要注意:

  • 不要对未锁定的读写锁解锁；
  • 对读锁不能使用写锁解锁
  • 对写锁不能使用读锁解锁

2、RWMutex使用实例

改写前面的取钱和存钱操作，添加查询余额的方法:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
package main
 
import (
  "fmt"
  "sync"
)
 
// account 代表计数器。
type account struct {
  num uint         // 操作次数
  balance int   // 余额
  rwMu  * sync .RWMutex // 读写锁
}
 
var sign = make (chan struct{}, 15) // 通道，用于等待所有goroutine
 
// 查看余额：使用读锁
func (c *account) check() {
  defer func() {
         sign <- struct{}{}
     }()
  c.rwMu.RLock()
  defer c.rwMu.RUnlock()
  fmt .Printf( "%d 次操作后的余额: %d\n" , c.num, c.balance)
}
 
// 存钱：写锁
func (c *account) deposit(value int) {
  defer func() {
         sign <- struct{}{}
     }()
     c.rwMu.Lock()
  defer c.rwMu.Unlock()
 
  fmt .Printf( "余额: %d\n" , c.balance)  
  c.num += 1
     c.balance += value
     fmt .Printf( "存 %d 后的余额: %d\n" , value, c.balance)
     fmt .Println()
}
 
// 取钱：写锁
func (c *account) withdraw(value int) {
     defer func() {
         sign <- struct{}{}
     }()
  c.rwMu.Lock()
  defer c.rwMu.Unlock()  
  fmt .Printf( "余额: %d\n" , c.balance)    
  c.num += 1
     c.balance -= value
  fmt .Printf( "取 %d 后的余额: %d\n" , value, c.balance)
     fmt .Println() 
}
 
 
func main() {
  c := account{0, 1000, new( sync .RWMutex)}
 
  for i:=0; i < 5; i++ {
         go c.withdraw(500) // 取500
         go c.deposit(500)  // 存500
   go c.check()
     }
 
     for i := 0; i < 15; i++ {
   <-sign
  }
  fmt .Printf( "%d 次操作后的余额: %d\n" , c.num, c.balance)
 
}

执行结果:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
余额: 1000
取 500 后的余额: 500
 
1 次操作后的余额: 500
1 次操作后的余额: 500
1 次操作后的余额: 500
1 次操作后的余额: 500
1 次操作后的余额: 500
余额: 500
存 500 后的余额: 1000
 
余额: 1000
取 500 后的余额: 500
 
余额: 500
存 500 后的余额: 1000
 
余额: 1000
存 500 后的余额: 1500
 
余额: 1500
取 500 后的余额: 1000
 
余额: 1000
取 500 后的余额: 500
 
余额: 500
存 500 后的余额: 1000
 
余额: 1000
取 500 后的余额: 500
 
余额: 500
存 500 后的余额: 1000
 
10 次操作后的余额: 1000

读写锁和互斥锁的不同之处在于读写锁把对共享资源的读操作和写操作分开了，可以实现更复杂的访问控制.

总结:

读写锁也是一种互斥锁，它是互斥锁的扩展。在使用时需要注意:

  • 加锁后一定要解锁
  • 不要重复加锁或者解锁
  • 不解锁未锁定的锁
  • 不要传递互斥锁

到此这篇关于Go语言并发编程之互斥锁Mutex和读写锁RWMutex的文章就介绍到这了,更多相关Go语言 Mutex RWMutex内容请搜索我以前的文章或继续浏览下面的相关文章希望大家以后多多支持我！ 。

原文链接：https://www.tuicool.com/articles/YFnIJz7 。

最后此篇关于Go语言并发编程之互斥锁Mutex和读写锁RWMutex的文章就讲到这里了,如果你想了解更多关于Go语言并发编程之互斥锁Mutex和读写锁RWMutex的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。

26 4 0
文章推荐： Python中的异常处理try/except/finally/raise用法分析
文章推荐： 记一次 K8S HostPort 引发的服务故障排错指南
文章推荐： python使用phoenixdb操作hbase的方法示例
文章推荐： Go select 死锁的一个细节
qq735679552
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com