go中常用的同步原语 ＜二＞ Mutex

有时候在Go代码中可能会存在多个goroutine同时操作一个资源（临界区），这种情况会发生竞态问题（数据竞态）。类比现实生活中的例子有十字路口被各个方向的的汽车竞争；还有火车上的卫生间被车厢里的人竞争。

//在没有锁的情况下
package main
import (
	"fmt"
	"time"
)
var n = 0
func count() {
	fmt.Println(n)
	n = n + 1
}
func main() {
	go count()
	go count()
	time.Sleep(1 * time.Hour)   
	//代码执行到这来 n的值是不确定的因为开启多个goroutine后 有线程安全问题
	//n的值有可能是2 ,也有可能是1
	//为了解决这个问题就需要我们今天的主角 Mutex 互斥锁了
}

互斥锁是一种常用的控制共享资源访问的方法，它能够保证同时只有一个goroutine可以访问共享资源。Go语言中使用sync包的Mutex类型来实现互斥锁。
使用互斥锁能够保证同一时间有且只有一个goroutine进入临界区，其他的goroutine则在等待锁；当互斥锁释放后，等待的goroutine才可以获取锁进入临界区，多个goroutine同时等待一个锁时，唤醒的策略是随机的。

使用互斥锁的代码如下

package main
import (
	"fmt"
	"sync"
	"time"
)
var n = 0
var mu = sync.Mutex{}
func count() {
	mu.Lock() //进入方法之后立刻上锁 防止其他goroutine拿到n的值
	defer mu.Unlock()  //执行完方法 开锁把操作权让给其他goroutine
	fmt.Println(n)
	n = n + 1
}
func main() {
	go count()
	go count()
	time.Sleep(1 * time.Hour)  //睡眠一段时间等待goroutine执行完毕
	//这里的n就一定会为2
}

引用:

• go语言学习文档
• 鱼儿老师的github 感谢鱼儿老师的示例