您的位置 首页 golang

【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() 调用会从获得的锁中排除新的读取器,即写锁权限高于读锁,有写锁时优先进行写锁定


文章来源:智云一二三科技

文章标题:【go】sync

文章地址:https://www.zhihuclub.com/478.shtml

关于作者: 智云科技

热门文章

发表评论

您的电子邮箱地址不会被公开。

网站地图