sync.Once 介绍

之前提到过 Go 的并发辅助对象:WaitGroup。同样的, sync.Once 也是 Go 官网的一并发辅助对象,它可能让函数办法只执行一次,达到相似 init 函数的成果。咱们来看看它的简略用法:

func main() {    var once sync.Once    onceFunc := func() {        fmt.Println("Only once")    }    for i := 0; i < 10; i++ {        once.Do(onceFunc)    }}

这里执行后咱们将只看到一次 Only once 的打印信息,这就是 sync.Once 的一次性成果。

sync.Once 源码

咱们来看下 sync.Once 的源码:

type Once struct {    done uint32    m    Mutex}func (o *Once) Do(f func()) {    // 原子加载标识值,判断是否已被执行过    if atomic.LoadUint32(&o.done) == 0 {        o.doSlow(f)    }}func (o *Once) doSlow(f func()) { // 还没执行过函数    o.m.Lock()    defer o.m.Unlock()    if o.done == 0 { // 再次判断下是否已被执行过函数        defer atomic.StoreUint32(&o.done, 1) // 原子操作:批改标识值        f() // 执行函数    }}

从下面能够剖析出,sync.Once 是通过对一个标识值,原子性的批改和加载,来缩小锁竞争的。


感兴趣的敌人能够搜一搜公众号「 阅新技术 」,关注更多的推送文章。
能够的话,就顺便点个赞、留个言、分享下,感激各位反对!
阅新技术,浏览更多的新常识。