临界资源:指并发编程中,可以被多个进程/线程/协程共同访问的资源。
如果在并发编程中对临界资源的处理不当,往往会导致数据不一致的问题。
火车站卖票问题demo,来演示临界资源安全问题
实现3个售票口同时售票
- //车票余量
- var tickets = 5
-
- //定义同步等待组
- var wg sync.WaitGroup
-
- func main() {
- wg.Add(3)
- go saleTickets("1号售票口")
- go saleTickets("2号售票口")
- go saleTickets("3号售票口")
- wg.Wait()
- }
-
- func saleTickets(name string) {
- for {
- if tickets > 0 {
- fmt.Printf("车票剩余:%v, %v售出\n", tickets, name)
- tickets--
- } else {
- fmt.Println("车票已售罄...")
- wg.Done()
- break
- }
- }
- }
我们的参数一共设置了5张车票,但是程序最后反馈售出了7张车票。这就是临界资源的安全问题。
3个goroutine在某个时刻判断车票数量是否大于0的时候,这个时刻车票数量都是满足的。但是在执行接下来的售票操作时,其中一个goroutine的售票口先把票卖出去了,但是其他两个售票口已经通过了逻辑判断,也将票卖了出去。
1.大多数语言解决同步资源安全问题都是通过上锁的方式。某一时刻只能允许一个goroutine来访问这个共享数据。go语言中,可以借助sync包下的锁操作。
2.在go语言的并发编程中有一句经典的话:不要以共享内存的方式去通信,而要以通信的方式去共享内存。Go语言鼓励使用channel将共享状态或共享状态的变化在各个goroutine之间传递,这样就可以像锁一样保证同一时刻只有一个goroutine访问共享状态。