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()
}()
相关文章
|
9天前
|
存储 JSON 监控
Viper,一个Go语言配置管理神器!
Viper 是一个功能强大的 Go 语言配置管理库,支持从多种来源读取配置,包括文件、环境变量、远程配置中心等。本文详细介绍了 Viper 的核心特性和使用方法,包括从本地 YAML 文件和 Consul 远程配置中心读取配置的示例。Viper 的多来源配置、动态配置和轻松集成特性使其成为管理复杂应用配置的理想选择。
30 2
|
14天前
|
JavaScript Java Go
探索Go语言在微服务架构中的优势
在微服务架构的浪潮中,Go语言以其简洁、高效和并发处理能力脱颖而出。本文将深入探讨Go语言在构建微服务时的性能优势,包括其在内存管理、网络编程、并发模型以及工具链支持方面的特点。通过对比其他流行语言,我们将揭示Go语言如何成为微服务架构中的一股清流。
108 53
|
8天前
|
Go 索引
go语言中的循环语句
【11月更文挑战第4天】
19 2
|
8天前
|
Go C++
go语言中的条件语句
【11月更文挑战第4天】
21 2
|
13天前
|
Ubuntu 编译器 Linux
go语言中SQLite3驱动安装
【11月更文挑战第2天】
37 7
|
13天前
|
关系型数据库 Go 网络安全
go语言中PostgreSQL驱动安装
【11月更文挑战第2天】
48 5
|
12天前
|
安全 Go
用 Zap 轻松搞定 Go 语言中的结构化日志
在现代应用程序开发中,日志记录至关重要。Go 语言中有许多日志库,而 Zap 因其高性能和灵活性脱颖而出。本文详细介绍如何在 Go 项目中使用 Zap 进行结构化日志记录,并展示如何定制日志输出,满足生产环境需求。通过基础示例、SugaredLogger 的便捷使用以及自定义日志配置,帮助你在实际开发中高效管理日志。
32 1
|
12天前
|
程序员 Go
go语言中的控制结构
【11月更文挑战第3天】
88 58
|
6天前
|
Go
go语言中的continue 语句
go语言中的continue 语句
16 3
|
11天前
|
监控 Go API
Go语言在微服务架构中的应用实践
在微服务架构的浪潮中,Go语言以其简洁、高效和并发处理能力脱颖而出,成为构建微服务的理想选择。本文将探讨Go语言在微服务架构中的应用实践,包括Go语言的特性如何适应微服务架构的需求,以及在实际开发中如何利用Go语言的特性来提高服务的性能和可维护性。我们将通过一个具体的案例分析,展示Go语言在微服务开发中的优势,并讨论在实际应用中可能遇到的挑战和解决方案。