温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

golang中sync.Once的示例分析

发布时间:2021-12-15 10:00:17 阅读:149 作者:小新 栏目:大数据
GO开发者专用服务器限时活动,0元免费领,库存有限,领完即止! 点击查看>>

这篇文章将为大家详细讲解有关golang中sync.Once的示例分析,小编觉得挺实用的,因此分享给大家做个参考,希望大家阅读完这篇文章后可以有所收获。

sync.once可以控制函数只能被调用一次,不能多次重复调用。

我们可以用下面的代码实现一个线程安全的单例模式

package singletonimport (    "fmt"    "sync")type object struct {    name string}var once sync.Oncevar obj *object //单例指针//公开方法 外包调用func Instance() *object {    once.Do(getObj)    return obj}func getObj() {    if obj == nil {        obj = new(object)        //可以做其他初始化事件    }}//单例测试func (obj *object) Test() {    fmt.Println(obj.name)}

如果我们要自己实现这么一个功能如何做呢?

  1. 定义一个status变量用来描述是否已经执行过了

  2. 使用sync.Mutex 或者sync.Atomic实现线程安全的获取status状态, 根据状态判断是否执行特定的函数

然后看下sync.Once实际是如何实现的

// Once is an object that will perform exactly one action.type Once struct {    m    Mutex    done uint32}//使用了双层检查机制 func (o *Once) Do(f func()) {    if atomic.LoadUint32(&o.done) == 1 {        return    }    // Slow-path.    o.m.Lock()    defer o.m.Unlock()    //这里需要再次重新判断下,因为 atomic.LoadUint32取出状态值到  o.m.Lock() 之间是有可能存在其它gotoutine改变status的状态值的    if o.done == 0 {        f()        atomic.StoreUint32(&o.done, 1)    }}

也有网友写出了更简洁的代码,不知道官方为什么没有采用下面的实现方式。

type Once struct {    done int32}func (o *Once) Do(f func()) {    if atomic.LoadInt32(&o.done) == 1 {        return    }    // Slow-path.    if atomic.CompareAndSwapInt32(&o.done, 0, 1) {        f()    }}

关于“golang中sync.Once的示例分析”这篇文章就分享到这里了,希望以上内容可以对大家有一定的帮助,使各位可以学到更多知识,如果觉得文章不错,请把它分享出去让更多的人看到。

亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>

向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

原文链接:https://my.oschina.net/u/4586289/blog/4634659

AI

开发者交流群×