【go】sync

sync.once能够控制函数只能被调用一次。不能屡次重复调用。

例如：保证channel 关闭只执行一次，避免关闭已关闭的channel致使panic

type MyChannel struct {
    C    chan T
    once sync.Once
}

func NewMyChannel() *MyChannel {
    return &MyChannel{C: make(chan T)}
}

func (mc *MyChannel) SafeClose() {
    mc.once.Do(func(){
        close(mc.C)
    })
}

更多的实现原理，参考：https://cloud.tencent.com/dev...

---

sync.Mutex 互斥锁
它可以保证同时只有一个 goroutine 能够访问到共享资源（同一个时刻只有一个线程可以拿到锁）
1.Lock() 加锁，Unlock() 解锁
2.在一个 goroutine 得到 Mutex 后，其余 goroutine 只能等到这个 goroutine 释放该 Mutex（阻塞住）
3.在同一个 goroutine 中的 Mutex 解锁以前再次进行加锁，会致使死锁（fatal error: all goroutines are asleep - deadlock!）
4.已经锁定的 Mutex 并不与特定的 goroutine 相关联，这样能够利用一个 goroutine 对其加锁，再利用其余 goroutine 对其解锁

---

sync.RWMutex读写锁
1.Lock() 加写锁，Unlock() 解写锁
2.RLock() 加读锁，RUnlock() 解读锁
3.RLock() 加读锁时，若是存在写锁，则没法加读锁；当只有读锁或者没有锁时，能够加读锁，读锁能够加载多个
4.若是在加写锁以前已经有其余的读锁和写锁，则 Lock() 会阻塞直到该锁可用，为确保该锁可用，已经阻塞的 Lock() 调用会从得到的锁中排除新的读取器，即写锁权限高于读锁，有写锁时优先进行写锁定