如何实现一个sync.Once

这篇具有很好参考价值的文章主要介绍了如何实现一个sync.Once。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

sync.Once 是 golang里用来实现单例的同步原语。Once 常常用来初始化单例资源,
或者并发访问只需初始化一次的共享资源,或者在测试的时候初始化一次测试资源。
单例,就是某个资源或者对象,只能初始化一次,类似全局唯一的变量。
一般都认为只要使用一个flag标记即可,然后使用原子操作这个flag,代码如下:

type XOnce struct {
	done uint32
}

func (x *XOnce) Do(f func()) {
	if atomic.CompareAndSwapUint32(&x.done, 0, 1)  {
		f()
	}
}

这种方式有很大的问题,就是如果参数f执行很慢,其他调用Do方法的goroutine,
虽然看到done已经设置过值,标记为已执行过,但是初始化资源的函数并未执行完,
在获取初始化资源的时候,可能会得到空的资源或者发生空指针的panic。

来看下go源码中是如何解决这个问题的。

type Once struct {
	m    sync.Mutex
	done uint32
}

func (x *Once) Do(f func()) {
	if atomic.LoadUint32(&x.done) == 0 {
		x.doSlow(f)
	}
}

func (x *Once) doSlow(f func()) {
	x.m.Lock()
	defer x.m.Unlock()

	if x.done == 0 {
		defer atomic.StoreUint32(&x.done, 1)
		f()
	}
}

Once类中有一个互斥锁和一个done标记。
用并发场景来校验一下,假设有两个goroutine同时调用Do方法,并进入doSlow,此时互斥锁的机制保证只有一个g能执行f。
同时利用双检查机制,再次判断x.done是否为,如果是0,则是第一次执行,执行完毕后,将x.done置为1,最后释放锁。
即时第二个g被唤醒了,但是由于此时的x.done==1,也就不会在执行f了。

双检查机制:既保证了并发的goroutine会等待f完成,而且还不会多次执行f文章来源地址https://www.toymoban.com/news/detail-434309.html

到了这里,关于如何实现一个sync.Once的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包赞助服务器费用

相关文章

  • Golang 线程安全与 sync.Map

    前言 线程安全通常是指在并发环境下,共享资源的访问被适当地管理,以防止竞争条件(race conditions)导致的数据不一致 Go语言中的线程安全可以通过多种方式实现 实现方式 互斥锁(Mutexes) Go的sync包提供了Mutex和RWMutex类型来确保在一个时间点只有一个协程可以访问某个资

    2024年01月24日
    浏览(34)
  • Golang 中的反射,并用来获取数据类型

    Go语言提供了一种机制在运行中获取某个变量的类型,获取或修改变量的值,调用变量的方法。 示例代码如下 通过 reflect.Value 判断变量类型,并转换成 string 。 输出结果: 输出结果:

    2024年01月22日
    浏览(12)
  • Golang中sync.Pool详解及使用方法

    sync.Pool是用来保存可以被重复使用的临时对象,以便在以后的同类操作中可以重复使用,从而避免了反复创建和销毁临时对象带来的消耗以及对GC造成的压力。常用池化技术来提高程序的性能,例如连接池、线程池等。sync.Pool是并发安全的,可以在多个goroutine中并发调用sync

    2024年02月02日
    浏览(6)
  • 学习如何在VS Code中创建一个Golang/Go项目,并运行一个简单的Golang程序

     学习如何在VS Code中创建一个Golang项目,并运行一个简单的Golang程序。 在VS Code 手动输入命令创建一个Golang项目 在VS Code 不输入命令创建一个Golang项目 1. 在VS Code 手动输入命令创建一个Golang项目 步骤1:在VS Code中创建一个新文件夹,用于存放Golang项目文件。 步骤2:打开VS

    2024年02月14日
    浏览(13)
  • 从源码角度剖析 golang 如何fork一个进程

    创建一个新进程分为两个步骤,一个是fork系统调用,一个是execve 系统调用,fork调用会复用父进程的堆栈,而execve直接覆盖当前进程的堆栈,并且将下一条执行指令指向新的可执行文件。 在分析源码之前,我们先来看看golang fork一个子进程该如何写。(👉严格的讲是先fork再

    2024年02月07日
    浏览(15)
  • 如何判断一个点是否在凸多边形内 - golang

    如何判断一个点是否在凸多边形内 - golang

    判断一个点是否在凸多边形内的方法很多,此处仅给出使用 向量叉积法 判断点是否在凸多边形内的方法。 以下图为例说明问题: 原理: 1. 将多边形的第 i 条边的第一个顶点指向点 P 得到向量 v1,然后将从第一个顶点指向第二个顶点得到向量 v2,叉乘这两个向量。 2. 如果叉

    2024年02月07日
    浏览(11)
  • Golang 实现一个简单的 RPC 服务

    分享一个简单的 rpc 服务框架 一、服务端实现 二、客户端实现

    2024年04月10日
    浏览(16)
  • 深入理解Kafka—如何保证Exactly Once语义

    作者:禅与计算机程序设计艺术 Kafka 是一种高吞吐量、分布式、可分区、多副本的消息系统。它在使用上非常灵活,可以作为 Pulsar、RabbitMQ 的替代品。但同时也带来了一些复杂性和问题,比如Exactly Once 语义。从本质上说,Exactly Once 就是对消费者读取的数据只要不丢失,就一

    2024年02月07日
    浏览(9)
  • Golang 搭建 WebSocket 应用(三) - 实现一个消息推送中心

    Golang 搭建 WebSocket 应用(三) - 实现一个消息推送中心

    有了前两篇的铺垫,相信大家已经对 Golang 中 WebSocket 的使用有一定的了解了, 今天我们以一个更加真实的例子来学习如何在 Golang 中使用 WebSocket 。 在实际的项目中,往往有一些任务耗时比较长,然后我们会把这些任务做异步的处理,但是又要及时给客户端反馈任务的处理进

    2024年01月23日
    浏览(13)
  • C++并发编程(6):单例模式、once_flag与call_once、call_once实现单例

    参考博客 【C++】单例模式(饿汉模式、懒汉模式) C++单例模式总结与剖析 饿汉单例模式 C++实现 C++单例模式(饿汉式) 设计模式(Design Pattern)是一套被反复使用、多数人知晓的、经过分类的、代码设计经验的总结 ,一共有23种经典设计模式 使用设计模式的目的 :为了代码可

    2024年02月16日
    浏览(9)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包