这篇文章将为大家详细讲解有关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)}
如果我们要自己实现这么一个功能如何做呢?
定义一个status变量用来描述是否已经执行过了
使用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元/月。点击查看>>
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。
原文链接:https://my.oschina.net/u/4586289/blog/4634659