func (*RWMutex)Lock()func (*RWMutex)Unlock()
func (*RWMutex)RLock()func (*RWMutex)RUnlock()
func printer(str string) {for _, data := range str {fmt.Printf("%c", data)}fmt.Println()}func person1() {printer("hello")}func person2() {printer("world")}func main() {go person1()person2()time.Sleep(time.Second)}//输出结果//worhello//ld
var mut sync.Mutexfunc printer(str string) {mut.Lock()defer mut.Unlock()for _, data := range str {fmt.Printf("%c", data)}fmt.Println()}func person1() {printer("hello")}func person2() {printer("world")}func main() {go person1()person2()time.Sleep(time.Second)}//输出结果//world//hello
不要重复锁定互斥锁:对一个已经被锁定的互斥锁进行锁定,是会立即阻塞当前的goroutine,这个 goroutine所执行的流程,会一直停滞在调用该互斥锁的Lock方法的那行代码上。(注意:这种由 Go 语言运行时系统自行抛出的 panic 都属于致命错误,都是无法被恢复的,调用recover函数对它们起不到任何作用。也就是说,一旦产生死锁,程序必然崩溃。)
不要忘记解锁互斥锁,必要时使用defer语句:因为在一个 goroutine 执行的流程中,可能会出现诸如“锁定、解锁、再锁定、再解锁”的操作,所以如果我们忘记了中间的解锁操作,那就一定会造成重复锁定。
var mutex sync.Mutexfunc write() {defer mutex.Unlock() // 通过defer解锁mutex.Lock()// 获取临界资源,执行具体逻辑...}
不要对尚未锁定或者已解锁的互斥锁解锁:这个程序会直接panic。
var mutex sync.Mutex // 定义互斥锁变量 mutexmutex.Lock()mutex.Unlock()mutex.Unlock() // fatal error: sync: unlock of unlocked mutexreturn
不要在多个函数之间直接传递互斥锁:互斥锁是一结构体类型,即值类型,把它传给一个函数、将它从函数中返回、把它赋给其他变量、让它进入某个通道都会导致它的副本的产生。因此,原值和它的副本、以及多个副本之间都是完全独立的,它们都是不同的互斥锁。
在写锁已被锁定的情况下再试图锁定写锁,会阻塞当前的 goroutine;
在写锁已被锁定的情况下试图锁定读锁,也会阻塞当前的 goroutine;
在读锁已被锁定的情况下试图锁定写锁,同样会阻塞当前的 goroutine;
在读锁已被锁定的情况下再试图锁定读锁,并不会阻塞当前的 goroutine;
解锁“读写锁中未被锁定的写锁”,会立即引发 panic,对于读锁也是如此。
var count intvar mutex sync.RWMutexfunc write(n int) {rand.Seed(time.Now().UnixNano())fmt.Printf("写 goroutine %d 正在写数据...\n", n)mutex.Lock()num := rand.Intn(500)count = numfmt.Printf("写 goroutine %d 写数据结束,写入新值 %d\n", n, num)mutex.Unlock()}func read(n int) {mutex.RLock()fmt.Printf("读 goroutine %d 正在读取数据...\n", n)num := countfmt.Printf("读 goroutine %d 读取数据结束,读到 %d\n", n, num)mutex.RUnlock()}func main() {for i := 0; i < 10; i++ {go read(i + 1)}for i := 0; i < 10; i++ {go write(i + 1)}time.Sleep(time.Second*5)}//输出结果读 goroutine 1 正在读取数据...读 goroutine 1 读取数据结束,读到 0读 goroutine 7 正在读取数据...读 goroutine 7 读取数据结束,读到 0读 goroutine 3 正在读取数据...读 goroutine 3 读取数据结束,读到 0读 goroutine 10 正在读取数据...读 goroutine 10 读取数据结束,读到 0读 goroutine 8 正在读取数据...读 goroutine 8 读取数据结束,读到 0读 goroutine 6 正在读取数据...读 goroutine 5 正在读取数据...读 goroutine 5 读取数据结束,读到 0写 goroutine 2 正在写数据...读 goroutine 4 正在读取数据...读 goroutine 4 读取数据结束,读到 0写 goroutine 4 正在写数据...写 goroutine 3 正在写数据...读 goroutine 2 正在读取数据...读 goroutine 2 读取数据结束,读到 0写 goroutine 9 正在写数据...读 goroutine 6 读取数据结束,读到 0写 goroutine 7 正在写数据...读 goroutine 9 正在读取数据...读 goroutine 9 读取数据结束,读到 0写 goroutine 6 正在写数据...写 goroutine 1 正在写数据...写 goroutine 8 正在写数据...写 goroutine 10 正在写数据...写 goroutine 5 正在写数据...写 goroutine 2 写数据结束,写入新值 365写 goroutine 4 写数据结束,写入新值 47写 goroutine 3 写数据结束,写入新值 468写 goroutine 9 写数据结束,写入新值 155写 goroutine 7 写数据结束,写入新值 112写 goroutine 6 写数据结束,写入新值 490写 goroutine 1 写数据结束,写入新值 262写 goroutine 8 写数据结束,写入新值 325写 goroutine 10 写数据结束,写入新值 103写 goroutine 5 写数据结束,写入新值 353