Go并发同步Mutex典型易错使用场景

func main() {
   var mu sync.Mutex
   defer mu.Unlock()
   fmt.Println("oh, missing Lock!")
}

type Counter struct {
   sync.Mutex
   Count int
}
func main() {
   var c Counter
   c.Lock()
   defer c.Unlock()
   c.Count++
   foo(c) // 复制锁
}
// 这里Counter的参数是通过复制的方式传入的
func foo(c Counter) {
   c.Lock()
   defer c.Unlock()
   fmt.Println("in foo")
}

var lockerType *types.Interface
 // Construct a sync.Locker interface type.
 func init() {
     nullary := types.NewSignature(nil, nil, nil, false) // func()
     methods := []*types.Func{
     types.NewFunc(token.NoPos, nil, "Lock", nullary),
     types.NewFunc(token.NoPos, nil, "Unlock", nullary),
 }
 lockerType = types.NewInterface(methods, nil).Complete()
 }

func foo(l sync.Locker) {
   fmt.Println("in foo")
   l.Lock()
   bar(l)
   l.Unlock()
}
func bar(l sync.Locker) {
   l.Lock()
   fmt.Println("in bar")
   l.Unlock()
}
func main() {
   l := &sync.Mutex{}
   foo(l)
}

//办理居住证
func main() {
   // 网签中心证明
   var psCertificate sync.Mutex
   // 社区证明
   var propertyCertificate sync.Mutex
   var wg sync.WaitGroup
   wg.Add(2) // 需要网签中心和社区都处理
   // 网签中心处理goroutine
   go func() {
      defer wg.Done() // 网签中心处理完成
      psCertificate.Lock()
      defer psCertificate.Unlock()
      // 检查材料
      time.Sleep(5 * time.Second)
      // 请求社区的证明
      propertyCertificate.Lock()
      propertyCertificate.Unlock()
   }()
   // 社区处理goroutine
   go func() {
      defer wg.Done() // 社区处理完成
      propertyCertificate.Lock()
      defer propertyCertificate.Unlock()
      // 检查材料
      time.Sleep(5 * time.Second)
      // 请求网签中心的证明
      psCertificate.Lock()
      psCertificate.Unlock()
   }()
   wg.Wait()
   fmt.Println("成功完成")
}