GO语言-10了解Go并发中锁的概念和使用(下)

简介: GO语言的学习与记录,10了解Go并发中锁的概念和使用(下),学习锁的概念,为什么需要锁;使用互斥锁解决临界区资源的问题
初心是记录和总结,自己学习Go语言的历程。如果能帮助到你,这是我的荣幸。

为什么要有锁?

为什么并发中要有锁的概念?我们从以下的1.2.3...说起

  1. 并发是开启了多个线程去做某一件事情,比如说抢包包的(秒杀行为)
  2. 多个线程如果同时去访问某一个资源的话,那么这个资源就被称为临界区
  3. CPU操作一个命令的时候,会这样执行:

控制器程序计时器读取执行指令的地址

控制器根据地址加载指令

控制器将指令交给运算器

运算器根据指令进行计算

模拟一个场景:双十一特惠,限量版包包限时秒杀,只需99元,仅此一个,代码如下

package main

import (
   "fmt"
   "sync"
   "time"
)

//定义只有一个包包
var x int = 1
var wg sync.WaitGroup

//定义购买的方法
func buy(name string) {
   // 判断如果包包还有的时候进入方法体
   if x > 0 {
      time.Sleep(time.Second)
      x = x - 1
      fmt.Printf("%s,买到了包\n", name)
   }
   defer func() {
      wg.Done()
   }()
}
func main() {
   // 使用WaitGroup管理协程
   wg.Add(3)
   go buy("小王")
   go buy("小明")
   go buy("张三")
   wg.Wait()
}

输出结果是:

小明,买到了包
张三,买到了包
小王,买到了包

最终,店家默默的流下了泪水。于是他抓到你这个程序员,质问你怎么回事!

在这个例子中,我们可以发现x是被多个协程访问了,说明它是一个临界区资源,对于临界区资源来说,处于并发的情况下,很不安全。三个协程同时访问了x,判断的时候是大于0的,于是都进行了方法体的操作。

对于这种临界区资源进行操作,需要保证操作的原子性,是一次仅允许一个进程使用

简单理解就是,x是临界资源,保证它一次操作仅允许一个进程使用,达成这种机制,Go语言给我们提供了

这里我们使用互斥锁来演示。互斥锁是:对共享数据进行锁定,保证同一时刻只能有一个线程去操作。

互斥锁 sync.Mutex

使用互斥锁很简单,Go语言的互斥锁是一个类,只需要实例化一把锁,对临界资源进行加锁解锁的动作即可。

注意:加锁和解锁是一组动作,如果加锁后不解锁,会造成 死锁

我们使用互斥锁对代码进行改进:

package main

import (
   "fmt"
   "sync"
   "time"
)

var x int = 1
var wg sync.WaitGroup
var lock sync.Mutex

func buy(name string) {
   // 在操作x临界资源时,加锁,保证每次只有一个协程操作
   lock.Lock()
   if x > 0 {
      time.Sleep(time.Second)
      x = x - 1
      fmt.Printf("%s,买到了包\n", name)
      lock.Unlock() // 如果买到包了记得解锁
   } else {
      lock.Unlock() // 这里是其它协程操作的时候,他们虽然抢到锁了,但是会判断x,如果没有包了,依然要把锁还回去
   }

   defer func() {
      wg.Done()
   }()
}
func main() {
   wg.Add(3)
   go buy("小王")
   go buy("小明")
   go buy("张三")
   wg.Wait()
}

结果输出:

小王,买到了包
目录
相关文章
|
17天前
|
Go 开发工具
百炼-千问模型通过openai接口构建assistant 等 go语言
由于阿里百炼平台通义千问大模型没有完善的go语言兼容openapi示例,并且官方答复assistant是不兼容openapi sdk的。 实际使用中发现是能够支持的,所以自己写了一个demo test示例,给大家做一个参考。
|
17天前
|
程序员 Go
go语言中结构体(Struct)
go语言中结构体(Struct)
92 71
|
16天前
|
存储 Go 索引
go语言中的数组(Array)
go语言中的数组(Array)
100 67
|
17天前
|
存储 Go
go语言中映射
go语言中映射
32 11
|
8天前
|
Go 数据安全/隐私保护 UED
优化Go语言中的网络连接:设置代理超时参数
优化Go语言中的网络连接:设置代理超时参数
|
17天前
|
存储 Go 索引
go语言中数组和切片
go语言中数组和切片
26 7
|
19天前
|
Go 索引
go语言for遍历数组或切片
go语言for遍历数组或切片
88 62
|
21天前
|
并行计算 安全 Go
Go语言中的并发编程:掌握goroutines和channels####
本文深入探讨了Go语言中并发编程的核心概念——goroutine和channel。不同于传统的线程模型,Go通过轻量级的goroutine和通信机制channel,实现了高效的并发处理。我们将从基础概念开始,逐步深入到实际应用案例,揭示如何在Go语言中优雅地实现并发控制和数据同步。 ####
|
19天前
|
Go
go语言for遍历映射(map)
go语言for遍历映射(map)
29 12
|
18天前
|
Go 索引
go语言使用索引遍历
go语言使用索引遍历
26 9