Go 临界资源 安全问题
临界资源安全的问题:
临界资源:
指并发环境中多个 进程/线程/协程 可以共享(都可以调用)的资源/变量,如果在并发环境中处理不当,就会造成一些 严重、问题
func main() {//临界资源a := 10go func() {a = 100fmt.Println("goroutine a:", a)}()a = 99fmt.Println("main goroutine a:", a)time.Sleep(1)}#输出: main goroutine a: 99 goroutine a: 100
临界资源安全问题:
并发本身并不复杂,但是有了 临界资源的竞争问题,就使得我们开发出来的并发程序变的复杂起来。应为会引起很多莫名其妙的问题。如果多个 goruotine 在访问同一个数据资源的时候,其中一个线程修改了数据,那么这个数据就被修改了,对于其他的 goroutine 来讲,这个数值很可能是不对的:
例如: 我们通过抢购牛奶,一共 10 箱,6个用户一直再抢
// 临界资源 10箱牛奶 var milk = 10func main() {go saleMilks("用户A")go saleMilks("用户B")go saleMilks("用户C")go saleMilks("用户D")go saleMilks("用户E")go saleMilks("用户F")time.Sleep(6 * time.Second) }func saleMilks(name string) {rand.Seed(time.Now().UnixNano())for {if milk > 0 {//模拟逻辑处理:先判断临界资源 然后逻辑处理消耗时间 释放CPU资源,别的 goroutine 可以继续执行time.Sleep(time.Duration(rand.Intn(1000)) * time.Millisecond)fmt.Println(name, "售出:", milk)milk--} else {fmt.Println("售罄, 没有奶了")break}} }// 程序输出: 用户D 售出: 10 用户B 售出: 10 用户F 售出: 10 用户E 售出: 10 用户C 售出: 10 用户A 售出: 10 用户F 售出: 4 用户F 售出: 3 用户B 售出: 2 用户E 售出: 1 售罄, 没有票了 用户A 售出: 0 售罄, 没有票了 用户B 售出: -1 售罄, 没有票了 用户F 售出: -2 售罄, 没有票了 用户C 售出: -3 售罄, 没有票了 用户D 售出: -4 售罄, 没有票了Process finished with the exit code 0很显然出现了 负数超卖的情况:
- 判断临界资源是否 大于 0
- 做相应处理。有可以是 写入 读取数据库,等其他操作。没有等待响应返回的时候,下一个 goroutine 已经开始执行了
- 这个时候 就有可能 发生 临界值不一直的情况
临界资源安全问题的解决:
想要解决临界资源安全问题,很多编程语言的方案都是同步,通过上锁的方式 某一时刻,只能容许一个 goroutine 来访问这个共享数据,当前 goroutine 访问完毕,解锁后 其他 goroutine 才能来访问。
我们可以借助于 sync 包下的 sync.Mutex 锁操作:
package mainimport ("fmt""math/rand""sync""time" )// 临界资源 10箱牛奶 var milk = 10var wg sync.WaitGroup var mutex sync.Mutex //创建锁头func main() {wg.Add(6) //这里设置个数的意义不大,应为有锁的存在 saleMilks 只容许 一个 goroutine 访问go saleMilks("用户A")go saleMilks("用户B")go saleMilks("用户C")go saleMilks("用户D")go saleMilks("用户E")go saleMilks("用户F")//time.Sleep(6 * time.Second)wg.Wait()fmt.Println("All tasks completed") }func saleMilks(name string) {defer wg.Done()// 在goroutine中使用Mutex保护共享资源mutex.Lock()defer mutex.Unlock()rand.Seed(time.Now().UnixNano())for {if milk > 0 {//模拟逻辑处理:先判断临界资源 然后逻辑处理消耗时间 释放CPU资源,别的 goroutine 可以继续执行time.Sleep(time.Duration(rand.Intn(1000)) * time.Millisecond)fmt.Println(name, "售出:", milk)milk--} else {fmt.Println(name, "售罄, 没有奶了")break}} }/// 输出: 这里看到 一直是 用户A 拿到资源,应为第一个 goroutine 就是用户A,只带他 执行完毕 自他的 goroutine 才继续执行, 从侧面也印证了 资源是一直 锁的状态, 没有释放锁之前 其他goroutine 进不来 用户A 售出: 10 用户A 售出: 9 用户A 售出: 8 用户A 售出: 7 用户A 售出: 6 用户A 售出: 5 用户A 售出: 4 用户A 售出: 3 用户A 售出: 2 用户A 售出: 1 用户A 售罄, 没有奶了 用户F 售罄, 没有奶了 用户C 售罄, 没有奶了 用户D 售罄, 没有奶了 用户E 售罄, 没有奶了 用户B 售罄, 没有奶了 All tasks completed
go 中临界资源的核心思路:
上面 锁 的思路在 go 语言中是不提倡的,只是使用上 相对更便捷一些!在 go 的并发编程中有一个很经典的话: 不要以共享内存的方式去通信, 而要以通信的方式共享内存。 在 go 语言中并不鼓励 用锁的方式共享资源,而是鼓励通过 channel 的方式共享状态或者共享状态 变化在各个 goroutine 之间传递(以通信的方式去共享内存),这样同样能像锁 一样保证在同一时刻只有一个 goroutine 访问共享资源。
当然 在主流的编程语言中为了保证多线程之间的共享数据安全性和一致性,都会提供一套基本的同步工具集,如锁 条件变量 原子操作等等。 go语言标准库 也豪不意外提供了这些机制,使用方式也和其他语言差不多。
使用通道实现锁
// 临界资源 10箱牛奶 var milk = 10var ch = make(chan struct{}, 1) // 创建一个有缓冲的通道作为信号量,容量为1,表示只能有一个goroutine可以通过func main() {go saleMilks("用户A")go saleMilks("用户B")go saleMilks("用户C")go saleMilks("用户D")go saleMilks("用户E")go saleMilks("用户F")time.Sleep(6 * time.Second)fmt.Println("All tasks completed") }func saleMilks(name string) {ch <- struct{}{} // 发送信号,获取锁// 释放锁rand.Seed(time.Now().UnixNano())for {if milk > 0 {//模拟逻辑处理:先判断临界资源 然后逻辑处理消耗时间 释放CPU资源,别的 goroutine 可以继续执行time.Sleep(time.Duration(rand.Intn(1000)) * time.Millisecond)fmt.Println(name, "售出:", milk)milk--} else {fmt.Println(name, "售罄, 没有奶了")break}}<-ch // 释放锁,从通道接收数据 }///输出: 用户A 售出: 10 用户A 售出: 9 用户A 售出: 8 用户A 售出: 7 用户A 售出: 6 用户A 售出: 5 用户A 售出: 4 用户A 售出: 3 用户A 售出: 2 用户A 售出: 1 用户A 售罄, 没有奶了 用户B 售罄, 没有奶了 用户D 售罄, 没有奶了 用户E 售罄, 没有奶了 用户F 售罄, 没有奶了 用户C 售罄, 没有奶了 All tasks completed
相关文章:
Go 临界资源 安全问题
临界资源安全的问题: 临界资源: 指并发环境中多个 进程/线程/协程 可以共享(都可以调用)的资源/变量,如果在并发环境中处理不当,就会造成一些 严重、问题 func main() {//临界资源a : 10go func() {a 100f…...
安卓常用控件(上)
文章目录 TextViewButtonEditText TextView textview主要用于在界面上显示一段文本信息。 属性名描述id给当前控件定义一个唯一的标识符。layout_width给控件指定一个宽度。match_parent:控件大小与父布局一样;wrap_content:控件大小刚好够包…...
基于 RabbitMQ 实现延迟消息的订单处理流程
文章目录 订单创建流程1. 商品查询与订单数据初始化2. 总价计算与订单保存3. 扣减库存与购物车清理4. 延迟消息与支付状态检测 订单延迟消息监听器支付成功与订单取消1. 订单支付成功2. 订单取消与库存恢复 总结 在现代电商系统中,订单处理是一个复杂且关键的环节。…...
使用Python将Word文档转换为PNG图片
在这篇博客中,我将介绍一个使用Python编写的小工具,它能够将指定文件夹中的所有Word文档(.doc和.docx格式)转换为PNG图片。这个工具基于wxPython库构建图形用户界面,并结合了win32com和PyMuPDF库实现文档格式的转换。接…...
Qt创建Json对象时浮点数的精度控制
我们在Qt中使用Json都是使用QJsonDocument、QJsonArray、QJsonObject、QJsonValue等类。 当我们在QJsonObject中插入浮点数字段时,会发现浮点数的小数位数很长,如下所示: #include <QJsonDocument> #include <QJsonArray> #incl…...
【海贼王航海日志:前端技术探索】CSS你了解多少?(二)
目录 1 -> 字体属性 1.1 -> 设置字体 1.2 -> 字体大小 1.3 -> 字体粗细 1.4 -> 文字样式 2 -> 文本属性 2.1 -> 文本颜色 2.1.1 -> 认识RGB 2.1.2 -> 设置文本颜色 2.2 -> 文本对齐 2.3 -> 文本装饰 2.4 -> 文本缩进 2.5 -&g…...
软件测试面试200问(全)
1、你的测试职业发展是什么? 测试经验越多,测试能力越高。所以我的职业发展是需要时间积累的,一步步向着高级测试工程师奔去。而且我也有初步的职业规划,前 3 年积累测试经验,按如何做好测试工程师的要点去要求自己&a…...
【单片机毕业设计选题24106】-基于阿里云的心率呼吸监测系统
系统功能: 上电后OLED显示 “欢迎使用请稍后”,两秒后显示Connecting...表示 正在连接阿里云,正常连接阿里云后进入系统显示界面,如长时间显示Connecting...请 检查WiFi网络是否正确。 系统连接阿里云后可在阿里云界面查看到系统上报的温…...
leetcode28:找出字符串第一个匹配的下标
找出字符串第一个匹配的下标 给你两个字符串 haystack 和 needle ,请你在 haystack 字符串中找出 needle 字符串的第一个匹配项的下标(下标从 0 开始)。如果 needle 不是 haystack 的一部分,则返回 -1 。 public int strStr(Str…...
Java二十三种设计模式-桥接模式(10/23)
桥接模式:解耦抽象与实现的灵活设计 引言 桥接模式(Bridge Pattern)是一种结构型设计模式,用于将抽象部分与其实现部分分离,使它们可以独立地变化。它是一种对象结构型模式,又称为柄体(Handle and Body)模…...
Java 面试指南
Java 面试指南 目录 引言Java 基础知识 数据类型运算符控制结构面向对象编程 Java 高级特性 异常处理集合框架泛型多线程与并发 Java 标准类库 java.lang 包java.util 包java.io 包 Java Web 开发 ServletJSPSpring 框架 数据库连接与JDBC JDBC 基础数据库连接池 设计模式 单…...
计算机毕业设计选题推荐-自习室座位预约系统-Java/Python项目实战
✨作者主页:IT毕设梦工厂✨ 个人简介:曾从事计算机专业培训教学,擅长Java、Python、微信小程序、Golang、安卓Android等项目实战。接项目定制开发、代码讲解、答辩教学、文档编写、降重等。 ☑文末获取源码☑ 精彩专栏推荐⬇⬇⬇ Java项目 Py…...
android13 删除兼容性警告窗口 deprecation warning 去除弃用警告
总纲 android13 rom 开发总纲说明 目录 1.前言 2.情况 3.问题分析 4.代码更改 5.编译测试 6.彩蛋 1.前言 在 Android 13 中,为了提高用户体验和应用的兼容性,系统引入了一些新的隐私和安全特性。这些特性可能会影响旧版应用的行为,因此当用户运行可能不完全兼容 An…...
JESD204B/C协议学习笔记
JESD204B基础概念 204B包含传输层,链路层,物理层。 应用层是对 JESD204B 进行配置的接口,在标准协议中是不含此层,只是为了便于理解,添加的一个层。 协议层指工程中生成的IP核JESD204B,负责处理输入的用户…...
网络安全-渗透测试工具及插件介绍和使用方法
1、Burp Suite Burp Suite 是用于攻击web 应用程序的集成平台。 是一款广泛使用的网络安全工具套件,主要用于测试Web应用程序的安全性。它可以帮助安全研究人员、渗透测试人员和开发人员发现和利用Web应用程序中的安全漏洞。 (1)下载和安装&a…...
JAVA WEB初步实验
Spring应用开发环境准备 安装配置Spring应用开发环境 熟悉IntelliJ IDEA开发工具 打开idea工具,创建普通Java工程 配置普通Java工程运行环境 得到基本的Java运行环境配置正常 修改pom.xml文件,搭建Spring IOC运行环境 更新pom文件 新建User、TestSpr…...
30 个 JavaScript 技巧,让你的代码更具可读性
1 、使用 !! 转换为布尔值 使用双重否定快速将任何值转换为布尔值。 let truthyValue !!1; // true let falsyValue !!0; // false 2 、 默认函数参数 设置函数参数的默认值以避免定义错误。 function greet(name "Guest") {return Hello, ${name}!; }greet(…...
电商行业中选择分账系统的关键因素!
分账是指将一笔交易的款项拆分成多个部分,按照预先设定的比例或规则分配给相关方。在电商行业中,分账通常是指将交易金额分给卖家、平台和其他相关方。 具体来说,分账可以帮助实现以下目标: 卖家结算:将顾客支付的货…...
通过继承实现状态模式(C++)
注意:先做类的声明和抽象基类的声明 抽象基类的函数方法中引入类,具体方法在类的实现后面声明。 在抽象基类的子类的函数中可以调用类的成员函数。 #include <iostream>using namespace std;class Contex;class state { public:virtual void Ha…...
全国多地公布2024下半年软考报名具体时间
下半年开考科目: 高级资格:系统分析师、系统架构设计师、网络规划设计师、系统规划与管理师 中级资格:软件设计师、网络工程师、信息安全工程师、信息系统监理师、多媒体应用设计师、系统集成项目管理工程师 初级资格:网络管理…...
浏览器访问 AWS ECS 上部署的 Docker 容器(监听 80 端口)
✅ 一、ECS 服务配置 Dockerfile 确保监听 80 端口 EXPOSE 80 CMD ["nginx", "-g", "daemon off;"]或 EXPOSE 80 CMD ["python3", "-m", "http.server", "80"]任务定义(Task Definition&…...
TDengine 快速体验(Docker 镜像方式)
简介 TDengine 可以通过安装包、Docker 镜像 及云服务快速体验 TDengine 的功能,本节首先介绍如何通过 Docker 快速体验 TDengine,然后介绍如何在 Docker 环境下体验 TDengine 的写入和查询功能。如果你不熟悉 Docker,请使用 安装包的方式快…...
如何在看板中体现优先级变化
在看板中有效体现优先级变化的关键措施包括:采用颜色或标签标识优先级、设置任务排序规则、使用独立的优先级列或泳道、结合自动化规则同步优先级变化、建立定期的优先级审查流程。其中,设置任务排序规则尤其重要,因为它让看板视觉上直观地体…...
Python Einops库:深度学习中的张量操作革命
Einops(爱因斯坦操作库)就像给张量操作戴上了一副"语义眼镜"——让你用人类能理解的方式告诉计算机如何操作多维数组。这个基于爱因斯坦求和约定的库,用类似自然语言的表达式替代了晦涩的API调用,彻底改变了深度学习工程…...
vue3 daterange正则踩坑
<el-form-item label"空置时间" prop"vacantTime"> <el-date-picker v-model"form.vacantTime" type"daterange" start-placeholder"开始日期" end-placeholder"结束日期" clearable :editable"fal…...
MFE(微前端) Module Federation:Webpack.config.js文件中每个属性的含义解释
以Module Federation 插件详为例,Webpack.config.js它可能的配置和含义如下: 前言 Module Federation 的Webpack.config.js核心配置包括: name filename(定义应用标识) remotes(引用远程模块࿰…...
PH热榜 | 2025-06-08
1. Thiings 标语:一套超过1900个免费AI生成的3D图标集合 介绍:Thiings是一个不断扩展的免费AI生成3D图标库,目前已有超过1900个图标。你可以按照主题浏览,生成自己的图标,或者下载整个图标集。所有图标都可以在个人或…...
从零手写Java版本的LSM Tree (一):LSM Tree 概述
🔥 推荐一个高质量的Java LSM Tree开源项目! https://github.com/brianxiadong/java-lsm-tree java-lsm-tree 是一个从零实现的Log-Structured Merge Tree,专为高并发写入场景设计。 核心亮点: ⚡ 极致性能:写入速度超…...
Redis专题-实战篇一-基于Session和Redis实现登录业务
GitHub项目地址:https://github.com/whltaoin/redisLearningProject_hm-dianping 基于Session实现登录业务功能提交版本码:e34399f 基于Redis实现登录业务提交版本码:60bf740 一、导入黑马点评后端项目 项目架构图 1. 前期阶段2. 后续阶段导…...
C++ vector容器存储对象和存储指针的区别(vector对象、vector指针)(存储指针时推荐使用智能指针)
文章目录 **1. 内存管理**- **存储对象**:- **存储指针**: **2. 生命周期控制**- **存储对象**:- **存储指针**: **3. 性能差异**- **存储对象**:- **存储指针**: **4. 使用场景**- **选择存储对象的情况**…...
