go语言中的Mutex

简介: go语言中的Mutex

Golang以其并发性Goroutines而闻名。不仅是并发,还有更多。


因此,在这种情况下,我们必须确保多个goroutines不应该同时试图修改资源,从而导致冲突。

为了确保资源一次只能被一个goroutine访问,我们可以使用一个叫做sync.Mutex的东西。


This concept is called mutual exclusion, and the conventional name for the data structure that provides it is mutex. — Go dev


无Mutex的用例

让我们有一个简单的用例来理解Mutexgoroutines中的使用。


例如,如果我们需要通过一个goroutine增加一个变量的值,并通过另一个goroutine减少同一个变量的值。


package main
import (
 "fmt"
 "sync"
 "time"
)
func main() {
 const loop = 100
 var wg sync.WaitGroup
 wg.Add(loop * 2)
 // declaring a shared value
 var n int = 0
 for i := 0; i < loop; i++ {
  go func() {
   time.Sleep(time.Second / 10)
   n++
   wg.Done()
  }()
  go func() {
   time.Sleep(time.Second / 10)
   n--
   wg.Done()
  }()
 }
 wg.Wait()
 // printing the final value of n
 if n != 0 {
  fmt.Println("The Final value of n should be 0. But found ", n)
  return
 }
 fmt.Printf("\nFinal value of n is %d\n\n", n) // the final of n should be 0
}


在这个循环中,我使用了两个带有goroutines的匿名函数。一个将增加n的值,另一个将减少n的值。在最后,n的值应该是0,因为初始值是0,对于每个循环计数,我都是先增后减,所以在最后应该和初始值一样。但如果不使用Mutex,情况就不是我们所期望的那样了。


在上述输出中,我们可以看到结果不是恒定的。


我们可以使用go run命令中的-race来检测是否存在数据竞赛。


数据竞赛发生在:一个进程中的两个或多个线程同时访问同一个内存位置。


sync.Mutex


它拥有两个方法:

  • Lock
  • Unlock


使用Lock来锁定资源,以便每次只有一个goroutine可以访问该资源。


Unlock用于解锁被锁住的资源。


使用Mutex也有同样的用例。


package main
import (
 "fmt"
 "sync"
 "time"
)
func main() {
 const loop = 100
 var wg sync.WaitGroup
 wg.Add(loop * 2)
 // declaring a shared value
 var n int = 0
 var m sync.Mutex
 for i := 0; i < loop; i++ {
  go func() {
   time.Sleep(time.Second / 10)
   m.Lock() // locking the resource n
   n++
   m.Unlock() // unlocking the resource n
   wg.Done()
  }()
  go func() {
   time.Sleep(time.Second / 10)
   m.Lock() // locking the resource n
   n--
   m.Unlock() // unlocking the resource n
   wg.Done()
  }()
 }
 wg.Wait()
 // printing the final value of n
 if n != 0 {
  fmt.Println("The Final value of n should be 0. But found ", n)
  return
 }
 fmt.Printf("\nFinal value of n is %d\n\n", n) // the final of n should be 0
}


在这里,两个goroutine试图同时访问同一个资源n。但在Mutex.Lock()的帮助下,我们可以锁定该资源,这样它就只能被一个goroutine使用。


                https://pic3.58cdn.com.cn/nowater/webim/big/n_v279ebe3c9be604171b1288266aee3452a.png


在上面的输出中,我们可以看到,输出总是0(正如我们所期望的)。


我们也可以在使用Mutex的时候检查数据竞赛。

                         


我们可以清楚地看到,在使用Mutex时没有数据竞赛。


另外,我们可以对资源Unlock()使用defer语句,所以它将在被锁定的块的末尾被解锁。

go func() {
  time.Sleep(time.Second / 10)
  m.Lock() // locking the resource n
  n--
  m.Unlock() // unlocking the resource n
  wg.Done()
}()
相关文章
|
5月前
|
存储 安全 Java
【Golang】(4)Go里面的指针如何?函数与方法怎么不一样?带你了解Go不同于其他高级语言的语法
结构体可以存储一组不同类型的数据,是一种符合类型。Go抛弃了类与继承,同时也抛弃了构造方法,刻意弱化了面向对象的功能,Go并非是一个传统OOP的语言,但是Go依旧有着OOP的影子,通过结构体和方法也可以模拟出一个类。
302 2
|
编译器 Go
揭秘 Go 语言中空结构体的强大用法
Go 语言中的空结构体 `struct{}` 不包含任何字段,不占用内存空间。它在实际编程中有多种典型用法:1) 结合 map 实现集合(set)类型;2) 与 channel 搭配用于信号通知;3) 申请超大容量的 Slice 和 Array 以节省内存;4) 作为接口实现时明确表示不关注值。此外,需要注意的是,空结构体作为字段时可能会因内存对齐原因占用额外空间。建议将空结构体放在外层结构体的第一个字段以优化内存使用。
|
运维 监控 算法
监控局域网其他电脑:Go 语言迪杰斯特拉算法的高效应用
在信息化时代,监控局域网成为网络管理与安全防护的关键需求。本文探讨了迪杰斯特拉(Dijkstra)算法在监控局域网中的应用,通过计算最短路径优化数据传输和故障检测。文中提供了使用Go语言实现的代码例程,展示了如何高效地进行网络监控,确保局域网的稳定运行和数据安全。迪杰斯特拉算法能减少传输延迟和带宽消耗,及时发现并处理网络故障,适用于复杂网络环境下的管理和维护。
|
7月前
|
Cloud Native 安全 Java
Go:为云原生而生的高效语言
Go:为云原生而生的高效语言
441 1
|
7月前
|
Cloud Native Go API
Go:为云原生而生的高效语言
Go:为云原生而生的高效语言
494 0
|
7月前
|
Cloud Native Java Go
Go:为云原生而生的高效语言
Go:为云原生而生的高效语言
333 0
|
7月前
|
Cloud Native Java 中间件
Go:为云原生而生的高效语言
Go:为云原生而生的高效语言
373 0
|
7月前
|
Cloud Native Java Go
Go:为云原生而生的高效语言
Go:为云原生而生的高效语言
419 0
|
7月前
|
数据采集 Go API
Go语言实战案例:多协程并发下载网页内容
本文是《Go语言100个实战案例 · 网络与并发篇》第6篇,讲解如何使用 Goroutine 和 Channel 实现多协程并发抓取网页内容,提升网络请求效率。通过实战掌握高并发编程技巧,构建爬虫、内容聚合器等工具,涵盖 WaitGroup、超时控制、错误处理等核心知识点。
|
7月前
|
数据采集 JSON Go
Go语言实战案例:实现HTTP客户端请求并解析响应
本文是 Go 网络与并发实战系列的第 2 篇,详细介绍如何使用 Go 构建 HTTP 客户端,涵盖请求发送、响应解析、错误处理、Header 与 Body 提取等流程,并通过实战代码演示如何并发请求多个 URL,适合希望掌握 Go 网络编程基础的开发者。