45. sync.Mutex 互斥和互斥锁 | 厚土Go学习笔记

channel 在 goroutine 中互相通信是非常合适且方便的。如果，我们不需要互相通信，只需要保证同一时刻只能有一个 goroutine 访问共享变量，以免冲突。我们该怎么做呢？这就需要用到互斥和互斥锁。

go 语言标准库中提供了 sync.Mutex 类型及两个方法: Lock 和 Unlock

我们可以通过在代码前加 Lock，在代码后加 Unlock 的方法，保证代码执行时的互斥性。

c.mux.Lock()    
c.v[key]++      //Lock之后，同一时刻只有一个 goroutine 能访问 c.v
c.mux.Unlock()

也可以用 defer 语句来保证互斥锁一定会被解锁。

c.mux.Lock()
defer c.mux.Unlock()

创建一个代码示例，先建立一个计数器结构体

//安全计数器，使用 sync.Mutex 保证安全
type SafeCounter struct {
    v map[string]int
    mux sync.Mutex
}

v 是计数器map，再加上一个 sync.Mutex 类型。

给 SafeCounter 增加两个方法，一个 inc 来实现计数器值累加，一个 Value 来实现取得当前计数器值。

//增加计数器 key 的计数值
func (c *SafeCounter) Inc(key string)  {
    c.mux.Lock()
    //Lock之后，同一时刻只有一个 goroutine 能访问 c.v
    c.v[key]++
    c.mux.Unlock()
}
//取得计数器当前值
func (c *SafeCounter) Value(key string) int {
    c.mux.Lock()
    defer c.mux.Unlock()
    return c.v[key]
}

主函数循环 100 次，使用 goroutine 让一个计数器去增加值。然后取得当前计数器的值。

为了避免运行太快，看不到效果，每次循环要间隔 100 毫秒。

time.Sleep(100*time.Millisecond)

完整代码示例

package main

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

//安全计数器，使用 sync.Mutex 保证安全
type SafeCounter struct {
    v map[string]int
    mux sync.Mutex
}

//增加计数器 key 的计数值
func (c *SafeCounter) Inc(key string)  {
    c.mux.Lock()
    //Lock之后，同一时刻只有一个 goroutine 能访问 c.v
    c.v[key]++
    c.mux.Unlock()
}

//取得计数器当前值
func (c *SafeCounter) Value(key string) int {
    c.mux.Lock()
    defer c.mux.Unlock()
    return c.v[key]
}
func main() {
    c := SafeCounter{v:make(map[string]int)}
    for i := 0; i < 100; i++{
        go c.Inc("somekey")
        time.Sleep(100*time.Millisecond)
        fmt.Println(c.Value("somekey"))
    }
    fmt.Println(c.Value("somekey"))
}

运行结果太长，不做展示。请自行实践。