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() 调用会从获得的锁中排除新的读取器,即写锁权限高于读锁,有写锁时优先进行写锁定
文章来源:智云一二三科技
文章标题:【go】sync
文章地址:https://www.zhihuclub.com/478.shtml