Go语言的数据竞争 (Data Race) 和 竞态条件 (Race Condition)

文章精选推荐

1 JetBrains Ai assistant 编程工具让你的工作效率翻倍
2 Extra Icons:JetBrains IDE的图标增强神器
3 IDEA插件推荐-SequenceDiagram,自动生成时序图
4 BashSupport Pro 这个ides插件主要是用来干嘛的 ?
5 IDEA必装的插件:Spring Boot Helper的使用与功能特点
6 Ai assistant ,又是一个写代码神器
7 Cursor 设备ID修改器,你的Cursor又可以继续试用了

文章正文

在并发编程中,数据竞争 (Data Race)竞态条件 (Race Condition) 是两个常见的问题,尤其在 Go 语言的 Goroutine 中使用共享数据时,更容易出现这些问题。它们的含义和根源有所不同,但都可能导致程序的不可预测行为。

1. 数据竞争 (Data Race)

定义

数据竞争是指两个或多个 Goroutine 同时访问同一个共享变量,并且至少有一个操作是写操作,且没有进行适当的同步

在这种情况下,程序的行为是未定义的,因为 Goroutine 的执行顺序可能不一致,导致共享变量的值难以预测。

示例代码

package mainimport ("fmt""time"
)func main() {var counter intfor i := 0; i < 10; i++ {go func() {counter++}()}time.Sleep(1 * time.Second)fmt.Println("Final Counter:", counter)
}
运行结果:
  • 每次运行,counter 的值可能不同,比如有时是 7,有时是 10,甚至更小。
  • 原因:多个 Goroutine 同时读写 counter,但没有任何同步措施,造成数据竞争。
修复方法

使用互斥锁(sync.Mutex)或其他同步机制。

package mainimport ("fmt""sync""time"
)func main() {var (counter intmu      sync.Mutex)for i := 0; i < 10; i++ {go func() {mu.Lock()counter++mu.Unlock()}()}time.Sleep(1 * time.Second)fmt.Println("Final Counter:", counter)
}

2. 竞态条件 (Race Condition)

定义

竞态条件是一种更广泛的问题,指程序的行为依赖于 Goroutine 的执行顺序,如果执行顺序发生改变,程序的逻辑可能出错。

竞态条件和数据竞争的区别

  • 数据竞争是竞态条件的一种表现形式。
  • 竞态条件可能存在于更高层次的逻辑上,即使没有共享数据,也可能由于执行顺序的不确定性导致错误。

示例代码

package mainimport ("fmt""sync"
)var balance intfunc Deposit(amount int, wg *sync.WaitGroup) {defer wg.Done()currentBalance := balancecurrentBalance += amountbalance = currentBalance
}func main() {var wg sync.WaitGroupbalance = 1000wg.Add(2)go Deposit(500, &wg) // Goroutine 1go Deposit(300, &wg) // Goroutine 2wg.Wait()fmt.Println("Final Balance:", balance)
}
运行结果:
  • 理想情况下,Final Balance 应该是 1000 + 500 + 300 = 1800
  • 实际运行可能得到错误结果,比如 15001300
  • 原因:两个 Goroutine 在读 balance 和写 balance 之间没有同步机制,导致执行顺序不同。
修复方法

使用互斥锁或原子操作确保更新是原子的。

package mainimport ("fmt""sync"
)var balance int
var mu sync.Mutexfunc Deposit(amount int, wg *sync.WaitGroup) {defer wg.Done()mu.Lock()defer mu.Unlock()balance += amount
}func main() {var wg sync.WaitGroupbalance = 1000wg.Add(2)go Deposit(500, &wg)go Deposit(300, &wg)wg.Wait()fmt.Println("Final Balance:", balance) // Correct result: 1800
}

3. 两者的区别

特点数据竞争 (Data Race)竞态条件 (Race Condition)
范围专注于并发时的共享变量访问问题更广泛,涵盖所有因执行顺序导致的问题
表现形式未同步的共享数据读写不正确的执行顺序导致逻辑错误
影响导致不可预测的值,程序行为未定义程序可能出错,结果不符合预期
是否需要同步机制必须对共享数据加锁或同步通常通过逻辑设计避免执行顺序依赖
诊断工具go run -race 可检测通常需要通过代码审查或测试发现

4. Go 语言的检测工具

Go 提供了内置的 -race 检测工具,可以帮助开发者快速发现数据竞争问题。

使用方法

go run -race main.go
示例输出

对于存在数据竞争的代码,-race 工具会输出类似以下的日志:

WARNING: DATA RACE
Read at 0x00c0000a4010 by goroutine 7:main.main.func1()/path/to/main.go:10 +0x45Previous write at 0x00c0000a4010 by goroutine 6:main.main.func1()/path/to/main.go:10 +0x45

注意

  • -race 工具的检测范围仅限于数据竞争,不能直接发现更高层次的竞态条件。
  • 使用 -race 会增加程序的运行时间和内存开销,但非常适合调试。

5. 最佳实践

为了避免数据竞争和竞态条件,在 Go 的并发编程中可以采用以下策略:

  1. 尽量避免共享数据

    • 使用 Goroutine 和 channel 传递数据,避免直接共享变量。
    • Go 提倡通过通信共享数据,而不是通过共享数据通信。
  2. 使用同步原语

    • 使用 sync.Mutexsync.RWMutex 保护共享数据。
    • 使用 sync.WaitGroup 等同步工具来确保 Goroutine 正确完成。
  3. 优先选择原子操作

    • 对于简单的计数器或布尔值更新,使用 sync/atomic 提供的原子操作。
  4. 使用检测工具

    • 在开发和测试阶段,始终运行带有 -race 的程序,检测数据竞争问题。
  5. 逻辑设计避免竞态

    • 设计程序时,尽量减少对执行顺序的依赖。
    • 确保程序逻辑在任何 Goroutine 执行顺序下都能正确运行。

6. 总结

  • 数据竞争 是竞态条件的一种特例,特指未同步的共享变量访问问题,而 竞态条件 则涵盖了所有执行顺序依赖导致的错误。
  • Go 语言通过 Goroutine 和 channel 提供了并发编程的强大能力,但开发者需要小心处理共享数据,避免数据竞争和竞态条件。
  • 利用 sync 包、atomic 包以及 -race 工具,可以有效防止和检测这些问题。

在并发编程中,始终秉持 清晰的同步策略简洁的设计哲学 是关键。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.rhkb.cn/news/2282.html

如若内容造成侵权/违法违规/事实不符,请联系长河编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

少一点If/Else - 状态模式(State Pattern)

状态模式&#xff08;State Pattern&#xff09; 状态模式&#xff08;State Pattern&#xff09;状态模式&#xff08;State Pattern&#xff09;概述状态模式&#xff08;State Pattern&#xff09;结构图状态模式&#xff08;State Pattern&#xff09;涉及的角色 talk is c…

mayavi -> python 3D可视化工具Mayavi的安装

前言 Mayavi是一个基于VTK&#xff08;Visualization Toolkit&#xff09;的科学计算和可视化工具&#xff0c;主要用于数据可视化和科学计算领域。 它提供了一系列的高级可视化工具&#xff0c;包括2D和3D图形、表面和体积渲染、流场可视化等。Mayavi可以通过Python脚本进行调…

idea 自动导包,并且禁止自动导 *(java.io.*)

自动导包配置 进入 idea 设置&#xff0c;可以按下图所示寻找位置&#xff0c;也可以直接输入 auto import 快速定位到配置。 Add unambiguous imports on the fly&#xff1a;自动帮我们优化导入的包Optimize imports on the fly&#xff1a;自动去掉一些没有用到的包 禁止导…

BI 是如何数据分析的?

企业部署商业智能BI前&#xff0c;需要进行详细的分析&#xff0c;了解BI能为企业带来多少价值&#xff1f;如何提高工作效率的等等&#xff0c;今天我们就来聊一聊 BI 的工作原理。 一、BI的取数方式 商业智能BI是通过访问和连接业务系统数据源数据库的方式来进行取数的&…

宇泰串口卡驱动在Ubuntu22.04编译、安装汇总

从官网下载驱动官网地址 上传到Ubuntu, 目录结构如下&#xff1a; 驱动源代码: 驱动代码是基于开源项目编译来的 编译路径不能有中文路径&#xff0c;否则可能有类似错误 源码是基于Linux2.3内核编译&#xff0c;我当前是6.8.0-51&#xff0c;数据结构有升级&#xff0c;需要调…

HarmonyOS 鸿蒙 ArkTs(5.0.1 13)实现Scroll下拉到顶刷新/上拉触底加载,Scroll滚动到顶部

HarmonyOS 鸿蒙 ArkTs(5.0.1 13)实现Scroll下拉到顶刷新/上拉触底加载 效果展示 使用方法 import LoadingText from "../components/LoadingText" import PageToRefresh from "../components/PageToRefresh" import FooterBar from "../components/…

上传自己的镜像到docker hub详细教程

上传自己的镜像到docker hub详细教程 本博客通B站视频一致&#xff1a; 上传自己的镜像到docker hub详细教程 1. 登录自己的hub.docker.com的账号 docker hub仓库 2. 点击Repositories&#xff0c;跳转到创建仓库页面 3. 点击Create a repository 创建repository&#xff0c…

[AI部署-tensorRT] customlayer定义添加过程解析

文章目录 tensorRT添加自定义层步骤1. trt如何解析onnx的&#xff1f; 整体流程图2. builtin_op_importor是干什么的&#xff1f;3. 怎么添加trt plugin4. 如何进行量化collection过程 references nvidia 官方plugin文档&#xff1a; https://www.nvidia.cn/content/dam/en-zz/…

[Do374]Ansible一键搭建sftp实现用户批量增删

[Do374]Ansible一键搭建sftp实现用户批量增删 1. 前言2. 思路3. sftp搭建及用户批量新增3.1 配置文件内容3.2 执行测试3.3 登录测试3.4 确认sftp服务器配置文件 4. 测试删除用户 1. 前言 最近准备搞一下RHCA LV V,外加2.9之后的ansible有较大变化于是练习下Do374的课程内容. 工…

易语言文字识别OCR

一.引言 文字识别&#xff0c;也称为光学字符识别&#xff08;Optical Character Recognition, OCR&#xff09;&#xff0c;是一种将不同形式的文档&#xff08;如扫描的纸质文档、PDF文件或数字相机拍摄的图片&#xff09;中的文字转换成可编辑和可搜索的数据的技术。随着技…

Docker 镜像制作原理 做一个自己的docker镜像

一.手动制作镜像 启动容器进入容器定制基于容器生成镜像 1.启动容器 启动容器之前我们首先要有一个镜像&#xff0c;这个镜像可以是从docker拉取&#xff0c;例如&#xff1a;现在pull一个ubuntu镜像到本机。 docker pull ubuntu:22.04 我们接下来可以基于这个容器进行容器…

网络编程 - - TCP套接字通信及编程实现

概述 TCP&#xff08;Transmission Control Protocol&#xff0c;传输控制协议&#xff09;是一种面向连接的、可靠的传输层协议。在网络编程中&#xff0c;TCP常用于实现客户端和服务器之间的可靠数据传输。本文将基于C语言实现TCP服务端和客户端建立通信的过程。 三次握手 在…

近红外简单ROI分析matlab(NIRS_SPM)

本次笔记主要想验证上篇近红外分析是否正确&#xff0c;因为叠加平均有不同的计算方法&#xff0c;一种是直接将每个通道的5分钟实时长单独进行叠加平均&#xff0c;另一种是将通道划分为1分钟的片段&#xff0c;将感兴趣的通道数据进行对应叠加平均&#xff0c;得到一个总平均…

从玩具到工业控制--51单片机的跨界传奇【2】

咱们在上一篇博客里面讲解了什么是单片机《单片机入门》&#xff0c;让大家对单片机有了初步的了解。我们今天继续讲解一些有关单片机的知识&#xff0c;顺便也讲解一下我们单片机用到的C语言知识。如果你对C语言还不太了解的话&#xff0c;可以看看博主的C语言专栏哟&#xff…

Python调用go语言编译的库

要在 Python 中调用用 Go 语言编写的库&#xff0c;可以使用 Go 语言的 cgo 特性将 Go 代码编译成共享库&#xff08;如 .so 文件&#xff09;&#xff0c;然后在 Python 中通过 ctypes 或 cffi 模块加载和调用这个共享库。 新建main.go文件&#xff0c;使用go语言编写如下代码…

学成在线_内容管理模块_创建模块工程

学成在线模块工程 1.各个微服务依赖基础工程2.每个微服务都是一个前后端分离的项目3.xuecheng-plus-content&#xff1a;内容管理模块工程xuecheng-plus-content-modelxuecheng-plus-content-servicexuecheng-plus-content-api 1.各个微服务依赖基础工程 2.每个微服务都是一个前…

1️⃣Java中的集合体系学习汇总(List/Map/Set 详解)

目录 01. Java中的集合体系 02. 单列集合体系​ 1. Collection系列集合的遍历方式 &#xff08;1&#xff09;迭代器遍历&#xff08;2&#xff09;增强for遍历​编辑&#xff08;3&#xff09;Lambda表达式遍历 03.List集合详解 04.Set集合详解 05.总结 Collection系列…

智能科技与共情能力加持,哈曼重新定义驾乘体验

2025年1月6日&#xff0c;拉斯维加斯&#xff0c;2025年国际消费电子展——想象一下&#xff0c;当您步入一辆汽车&#xff0c;它不仅能响应您的指令&#xff0c;更能理解您的需求、适应您的偏好&#xff0c;并为您创造一个独特且专属的交互环境。作为汽车科技领域的知名企业和…

Unity中实现倒计时结束后干一些事情

问题描述&#xff1a;如果我们想实现在一个倒计时结束后可以执行某个方法&#xff0c;比如挑战成功或者挑战失败&#xff0c;或者其他什么的比如生成boss之类的功能&#xff0c;而且你又不想每次都把代码复制一遍&#xff0c;那么就可以用下面这种方法。 结构 实现步骤 创建一…

从0开始学习搭网站第二天

前言&#xff1a;今天比较惭愧&#xff0c;中午打铲吃了一把&#xff0c;看着也到钻二了&#xff0c;干脆顺手把这个赛季的大师上了&#xff0c;于是乎一直到网上才开始工作&#xff0c;同样&#xff0c;今天的学习内容大多来自mdn社区mdn 目录 怎么把文件上传到web服务器采用S…