当前位置: 首页 > news >正文

Golang 并发机制-2:Golang Goroutine 和竞争条件

在今天的软件开发中,我们正在使用并发的概念,它允许一次执行多个任务。在Go编程中,理解Go例程是至关重要的。本文试图详细解释什么是例程,它们有多轻,通过简单地使用“go”关键字创建它们,以及可能出现的竞争条件和共享数据问题等主要同步困难。

Goroutine 介绍

Goroutine 是 Go 编程语言中并发编程的基本构建块。它本质上是一个轻量级的执行线程,在 Go 程序中与其他 Goroutine 并行运行。与其它编程语言中的传统线程不同,Goroutine 由 Go 运行时管理,在内存和 CPU 利用率方面都更高效。

  • 性质与效率

Goroutine的突出特性之一是它们的轻量级特性。传统线程可能是资源密集型的,会消耗大量的内存和CPU资源。相比之下,gooutine非常高效,支持创建数千个这样的例程,而不会造成显著的开销。

Goroutine的效率源于它们能够跨较少数量的OS线程进行多路复用,并根据工作负载动态调整其分配。这意味着Go程序可以有效地利用多个内核和处理器,而不需要大量的手动线程管理。
在这里插入图片描述

Goroutine示例(‘ go ’关键字)

在Go中创建Goroutine非常简单,这要归功于“Go”关键字。当你在函数调用前加上‘ go ’时,go会创建新的gooutine来并发地执行该函数。

import ("fmt""time"
)func sayHello() {for i := 0; i < 5; i++ {fmt.Println("Hello, World!")time.Sleep(time.Millisecond * 500)}
}func main() {go sayHello() // Start a new Goroutinetime.Sleep(time.Second * 2)fmt.Println("Main function")
}

在上面的例子中,‘ sayHello ’函数与‘ main ’函数并发执行,使其成为在Go中利用并发性的一种简单而有效的方法。

竞争条件

虽然在并发编程中提供了许多优点,但它们也带来了必须小心管理的同步挑战

什么是竞态条件?

当多个Goroutine(轻量级线程)并发地访问共享数据,并且其中至少有一个需要修改数据时,就会出现竞争条件。竞争条件会导致不可预测的结果,因为执行顺序无法保证。它们可能导致数据损坏、崩溃或错误的程序行为。

竞态条件示例:

package mainimport ("fmt""sync"
)var sharedCounter int
var wg sync.WaitGroupfunc increment() {for i := 0; i < 10000; i++ {sharedCounter++}wg.Done()
}func main() {wg.Add(2)go increment()go increment()wg.Wait()fmt.Println("Shared Counter:", sharedCounter)
}

在本例中,两个goroutine在没有同步的情况下并发地增加‘ sharedCounter ’变量。这可能导致竞争条件,其中‘ sharedCounter ’的最终值是不可预测的,并且可能是不正确的。

假设 sharedCounter 的初始值为 0,两个 goroutine 同时读取到 0,然后分别加 1 并写回内存,最终 sharedCounter 的值会是 1 而不是 2。为了避免竞争条件,可以使用同步机制,如互斥锁(sync.Mutex)来保护对共享资源的访问。

规避竞争条件

为了消除Go中的竞争条件,你可以使用同步原语,例如互斥锁(互斥锁的简称)。互斥锁确保一次只有一个程序可以访问代码的关键部分。下面是上一个例子的更新版本,使用互斥锁进行正确的同步:

package mainimport ("fmt""sync"
)var sharedCounter int
var wg sync.WaitGroup
var mu sync.Mutexfunc increment() {for i := 0; i < 10000; i++ {mu.Lock()sharedCounter++mu.Unlock()}wg.Done()
}func main() {wg.Add(2)go increment()go increment()wg.Wait()fmt.Println("Shared Counter:", sharedCounter)
}

在修改后的代码中,我们使用‘ mu ’互斥锁来保护‘ sharedCounter ’被修改的代码的临界区。通过锁定和解锁互斥锁,我们确保一次只有一个Goroutine可以访问和修改‘ sharedCounter ’,从而消除了竞争条件。

理解共享数据问题

Go中的共享数据问题发生在多个线程在没有适当同步的情况下并发访问和操作共享数据时。这些问题主要表现为两种形式:

  1. 数据竞争:当两个或多个例程同时访问共享数据时,就会发生数据竞争,从而导致不可预测的结果。数据竞争可能导致数据损坏或不正确的程序行为。

  2. 死锁:当线程被卡住时,会发生死锁,等待彼此释放资源。这可能导致程序陷入停滞。

为了缓解Go中的共享数据问题,开发人员应该使用适当的同步机制,如互斥锁、通道和其他同步原语。以下是一些最佳做法:

  • 使用互斥锁:使用互斥锁保护共享数据,以确保一次只有一个线程可以访问它。
  • 使用通道:通道为程序提供了一种安全的方式来通信和共享数据。它们通过确保对共享数据的受控访问来防止数据竞争。
  • 避免循环依赖:在创建循环依赖时要小心,因为在循环依赖中,各例程会等待彼此释放资源,从而导致死锁。

总之,在用Go编写并发程序时,管理竞争条件和共享数据问题是至关重要的。通过理解这些问题并实现适当的同步技术,开发人员可以创建健壮可靠的并发应用程序,充分利用Go的并发支持,同时避免与共享数据操作相关的陷阱。

最后总结

总之,Go程序是Go编程语言的一个强大功能,它提供了一种轻量级且高效的方式来实现并发性。通过使用“go”关键字,开发人员可以轻松地创建并发执行任务的goroutine。然而,在用Go构建并发应用程序时,必须意识到同步挑战,比如竞争条件和共享数据问题,并采用适当的技术来解决这些问题。

相关文章:

Golang 并发机制-2:Golang Goroutine 和竞争条件

在今天的软件开发中&#xff0c;我们正在使用并发的概念&#xff0c;它允许一次执行多个任务。在Go编程中&#xff0c;理解Go例程是至关重要的。本文试图详细解释什么是例程&#xff0c;它们有多轻&#xff0c;通过简单地使用“go”关键字创建它们&#xff0c;以及可能出现的竞…...

深入剖析 CSRF 漏洞:原理、危害案例与防护

目录 前言 漏洞介绍 漏洞原理 产生条件 产生的危害 靶场练习 post 请求csrf案例 防御措施 验证请求来源 设置 SameSite 属性 双重提交 Cookie 结语 前言 在网络安全领域&#xff0c;各类漏洞层出不穷&#xff0c;时刻威胁着用户的隐私与数据安全。跨站请求伪造&…...

C++和Python实现SQL Server数据库导出数据到S3并导入Redshift数据仓库

用C实现高性能数据处理&#xff0c;Python实现操作Redshift导入数据文件。 在Visual Studio 2022中用C和ODBC API导出SQL Server数据库中张表中的所有表的数据为CSV文件格式的数据流&#xff0c;用逗号作为分隔符&#xff0c;用双引号包裹每个数据&#xff0c;字符串类型的数据…...

AI大模型开发原理篇-5:循环神经网络RNN

神经概率语言模型NPLM也存在一些明显的不足之处:模型结构简单&#xff0c;窗口大小固定&#xff0c;缺乏长距离依赖捕捉&#xff0c;训练效率低&#xff0c;词汇表固定等。为了解决这些问题&#xff0c;研究人员提出了一些更先进的神经网络语言模型&#xff0c;如循环神经网络、…...

4-图像梯度计算

文章目录 4.图像梯度计算(1)Sobel算子(2)梯度计算方法(3)Scharr与Laplacian算子4.图像梯度计算 (1)Sobel算子 图像梯度-Sobel算子 Sobel算子是一种经典的图像边缘检测算子,广泛应用于图像处理和计算机视觉领域。以下是关于Sobel算子的详细介绍: 基本原理 Sobel算子…...

数据结构与算法 —— 常用算法模版

数据结构与算法 —— 常用算法模版 二分查找素数筛最大公约数与最小公倍数 二分查找 人间若有天堂&#xff0c;大马士革必在其中&#xff1b;天堂若在天空&#xff0c;大马士革必与之齐名。 —— 阿拉伯谚语 算法若有排序&#xff0c;二分查找必在其中&#xff1b;排序若要使用…...

DDD - 领域事件_解耦微服务的关键

文章目录 Pre领域事件的核心概念领域事件的作用领域事件的识别领域事件的技术实现领域事件的运行机制案例领域事件驱动的优势 Pre DDD - 微服务设计与领域驱动设计实战(中)_ 解决微服务拆分难题 EDA - Spring Boot构建基于事件驱动的消息系统 领域事件的核心概念 领域事件&a…...

芯片AI深度实战:实战篇之vim chat

利用vim-ollama这个vim插件&#xff0c;可以在vim内和本地大模型聊天。 系列文章&#xff1a; 芯片AI深度实战&#xff1a;基础篇之Ollama-CSDN博客 芯片AI深度实战&#xff1a;基础篇之langchain-CSDN博客 芯片AI深度实战&#xff1a;实战篇之vim chat-CSDN博客 芯片AI深度…...

【产品经理学习案例——AI翻译棒出海业务】

前言&#xff1a; 本文主要讲述了硬件产品在出海过程中&#xff0c;翻译质量、翻译速度和本地化落地策略是硬件产品规划需要考虑的核心因素。针对不同国家&#xff0c;需要优化翻译质量和算法&#xff0c;关注市场需求和文化差异&#xff0c;以便更好地满足当地用户的需求。同…...

解决运行npm时报错

在运行一个Vue项目时报错&#xff0c;产生下面问题 D:\node\npm.cmd run dev npm WARN logfile could not be created: Error: EPERM: operation not permitted, open D:\node\node_cache\_logs\2025-01-31T01_01_58_076Z-debug-0.log npm WARN logfile could not be created:…...

【07-编译工程与导入网表】

这里写自定义目录标题 一丶编译原理图编译默认属性一丶编译项目二丶输出BOM材料报告优化EXCEL-BOM清单 三丶输出PDF原理图给维修人员看 四丶导入网格表查看是否有错误常见错误 其他问题什么是位号(C1)?EXCEL添加序号列和居中显示?位号(序号)与单位(型号)EXCEL设置自动换行 编…...

FireFox | Google Chrome | Microsoft Edge 禁用更新 final版

之前的方式要么失效&#xff0c;要么对设备有要求&#xff0c;这次梳理一下对设备、环境几乎没有要求的通用方式&#xff0c;universal & final 版。 1.Firefox 方式 FireFox火狐浏览器企业策略禁止更新_火狐浏览器禁止更新-CSDN博客 这应该是目前最好用的方式。火狐也…...

conda配置channel

你收到 CondaKeyError: channels: value https://mirrors.tuna.tsinghua.edu.cn/anaconda/pkgs/main not present in config 错误是因为该镜像源&#xff08;https://mirrors.tuna.tsinghua.edu.cn/anaconda/pkgs/main&#xff09;可能没有被正确添加到 Conda 的配置文件中&…...

【MQ】探索 Kafka

基本概念 主题&#xff1a;Topic。主题是承载消息的逻辑容器&#xff0c;在实际使用中多用来区分具体的业务。 分区&#xff1a;Partition。一个有序不变的消息序列。每个主题下可以有多个分区。消息位移&#xff1a;Offset。表示分区中每条消息的位置信息&#xff0c;是一个…...

Workbench 中的热源仿真

探索使用自定义工具对移动热源进行建模及其在不同行业中的应用。 了解热源动力学 对移动热源进行建模为各种工业过程和应用提供了有价值的见解。激光加热和材料加工使用许多激光束来加热、焊接或切割材料。尽管在某些情况下&#xff0c;热源 &#xff08;q&#xff09; 不是通…...

计算机网络 笔记 网络层 3

IPv6 IPv6 是互联网协议第 6 版&#xff08;Internet Protocol Version 6&#xff09;的缩写&#xff0c;它是下一代互联网协议&#xff0c;旨在解决 IPv4 面临的一些问题&#xff0c;以下是关于 IPv6 的详细介绍&#xff1a; 产生背景&#xff1a; 随着互联网的迅速发展&…...

翼星求生服务器搭建【Icarus Dedicated Server For Linux】

一、前言 本次搭建的服务器为Steam平台一款名为Icarus的沙盒、生存、建造游戏,由于官方只提供了Windows版本服务器导致很多热爱Linux的小伙伴无法释怀,众所周知Linux才是专业服务器的唯一准则。虽然Github上已经有大佬制作了容器版本但是容终究不够完美,毕竟容器无法与原生L…...

ZZNUOJ(C/C++)基础练习1011——1020(详解版)

目录 1011 : 圆柱体表面积 C语言版 C版 1012 : 求绝对值 C语言版 C版 1013 : 求两点间距离 C语言版 C版 1014 : 求三角形的面积 C语言版 C版 1015 : 二次方程的实根 C语言版 C版 1016 : 银行利率 C语言版 C版 1017 : 表面积和体积 C语言版 C版 代码逻辑…...

论文阅读:Realistic Noise Synthesis with Diffusion Models

这篇文章是 2025 AAAI 的一篇工作&#xff0c;主要介绍的是用扩散模型实现对真实噪声的仿真模拟 Abstract 深度去噪模型需要大量来自现实世界的训练数据&#xff0c;而获取这些数据颇具挑战性。当前的噪声合成技术难以准确模拟复杂的噪声分布。我们提出一种新颖的逼真噪声合成…...

复杂场景使用xpath定位元素

在复杂场景下使用XPath定位元素时&#xff0c;可以通过以下高级技巧提高定位准确性和稳定性&#xff1a; 动态属性处理 模糊匹配&#xff1a; //div[contains(id, dynamic-part)] //button[starts-with(name, btn-)] //input[ends-with(class, -input)] (需XPath 2.0)多属性…...

地震勘探——干扰波识别、井中地震时距曲线特点

目录 干扰波识别反射波地震勘探的干扰波 井中地震时距曲线特点 干扰波识别 有效波&#xff1a;可以用来解决所提出的地质任务的波&#xff1b;干扰波&#xff1a;所有妨碍辨认、追踪有效波的其他波。 地震勘探中&#xff0c;有效波和干扰波是相对的。例如&#xff0c;在反射波…...

K8S认证|CKS题库+答案| 11. AppArmor

目录 11. AppArmor 免费获取并激活 CKA_v1.31_模拟系统 题目 开始操作&#xff1a; 1&#xff09;、切换集群 2&#xff09;、切换节点 3&#xff09;、切换到 apparmor 的目录 4&#xff09;、执行 apparmor 策略模块 5&#xff09;、修改 pod 文件 6&#xff09;、…...

Zustand 状态管理库:极简而强大的解决方案

Zustand 是一个轻量级、快速和可扩展的状态管理库&#xff0c;特别适合 React 应用。它以简洁的 API 和高效的性能解决了 Redux 等状态管理方案中的繁琐问题。 核心优势对比 基本使用指南 1. 创建 Store // store.js import create from zustandconst useStore create((set)…...

DockerHub与私有镜像仓库在容器化中的应用与管理

哈喽&#xff0c;大家好&#xff0c;我是左手python&#xff01; Docker Hub的应用与管理 Docker Hub的基本概念与使用方法 Docker Hub是Docker官方提供的一个公共镜像仓库&#xff0c;用户可以在其中找到各种操作系统、软件和应用的镜像。开发者可以通过Docker Hub轻松获取所…...

JavaScript 中的 ES|QL:利用 Apache Arrow 工具

作者&#xff1a;来自 Elastic Jeffrey Rengifo 学习如何将 ES|QL 与 JavaScript 的 Apache Arrow 客户端工具一起使用。 想获得 Elastic 认证吗&#xff1f;了解下一期 Elasticsearch Engineer 培训的时间吧&#xff01; Elasticsearch 拥有众多新功能&#xff0c;助你为自己…...

涂鸦T5AI手搓语音、emoji、otto机器人从入门到实战

“&#x1f916;手搓TuyaAI语音指令 &#x1f60d;秒变表情包大师&#xff0c;让萌系Otto机器人&#x1f525;玩出智能新花样&#xff01;开整&#xff01;” &#x1f916; Otto机器人 → 直接点明主体 手搓TuyaAI语音 → 强调 自主编程/自定义 语音控制&#xff08;TuyaAI…...

Android15默认授权浮窗权限

我们经常有那种需求&#xff0c;客户需要定制的apk集成在ROM中&#xff0c;并且默认授予其【显示在其他应用的上层】权限&#xff0c;也就是我们常说的浮窗权限&#xff0c;那么我们就可以通过以下方法在wms、ams等系统服务的systemReady()方法中调用即可实现预置应用默认授权浮…...

爬虫基础学习day2

# 爬虫设计领域 工商&#xff1a;企查查、天眼查短视频&#xff1a;抖音、快手、西瓜 ---> 飞瓜电商&#xff1a;京东、淘宝、聚美优品、亚马逊 ---> 分析店铺经营决策标题、排名航空&#xff1a;抓取所有航空公司价格 ---> 去哪儿自媒体&#xff1a;采集自媒体数据进…...

Linux --进程控制

本文从以下五个方面来初步认识进程控制&#xff1a; 目录 进程创建 进程终止 进程等待 进程替换 模拟实现一个微型shell 进程创建 在Linux系统中我们可以在一个进程使用系统调用fork()来创建子进程&#xff0c;创建出来的进程就是子进程&#xff0c;原来的进程为父进程。…...

Go 语言并发编程基础:无缓冲与有缓冲通道

在上一章节中&#xff0c;我们了解了 Channel 的基本用法。本章将重点分析 Go 中通道的两种类型 —— 无缓冲通道与有缓冲通道&#xff0c;它们在并发编程中各具特点和应用场景。 一、通道的基本分类 类型定义形式特点无缓冲通道make(chan T)发送和接收都必须准备好&#xff0…...