使用互斥锁(Mutex)管理共享资源

2023-12-24 00:12

本文主要是介绍使用互斥锁(Mutex)管理共享资源,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

在这里插入图片描述

在Go中确保并发安全性

并发是Go中的一个强大功能,它允许多个Goroutines(并发线程)同时执行。然而,伴随着强大的功能也带来了大量的责任。当多个Goroutines并发地访问和修改共享资源时,可能会导致数据损坏、数据竞争(race conditions)和不可预测的程序行为。为了解决这些问题,Go提供了一种称为互斥锁(Mutex,互斥排他锁的缩写)的同步原语。在本文中,我们将探讨互斥锁在管理共享资源中的作用,以及在并发编程中使用它的必要性。

互斥锁简介

互斥锁是一种同步原语,用于提供对共享资源或代码关键部分的独占访问。它充当了门卫的角色,一次只允许一个Goroutine访问和修改受保护的资源。当一个Goroutine持有互斥锁时,所有试图获取它的其他Goroutines都必须等待。

互斥锁提供了两个基本方法:

  • Lock(): 这个方法获取互斥锁,授予对资源的独占访问。如果另一个Goroutine已经持有该互斥锁,新的Goroutine将被阻塞,直到它被释放。
  • Unlock(): 这个方法释放互斥锁,允许其他等待的Goroutines获取它并访问资源。

互斥锁的必要性

使用互斥锁的原因在于,当多个Goroutines并发访问共享资源时,这些资源容易遭受数据竞争和不一致性的风险。以下是互斥锁至关重要的一些常见场景:

1. 数据竞争

数据竞争发生在多个Goroutines并发访问共享数据时,其中至少一个Goroutine对其进行修改。这可能导致不可预测和错误的行为,因为执行顺序是不确定的。互斥锁通过一次只允许一个Goroutine访问共享资源来帮助防止数据竞争。

package mainimport ("fmt""sync"
)var sharedData int
var mu sync.Mutexfunc increment() {mu.Lock()sharedData++mu.Unlock()
}func main() {var wg sync.WaitGroupfor i := 0; i < 100; i++ {wg.Add(1)go func() {defer wg.Done()increment()}()}wg.Wait()fmt.Println("Shared Data:", sharedData)
}

在这个示例中,多个Goroutines并发地增加sharedData变量,如果没有使用互斥锁,这将导致数据竞争。

2. 临界区(Critical Sections)

临界区是访问共享资源的代码部分。当多个Goroutines试图同时访问同一个临界区时,可能会导致不可预测的行为。互斥锁确保一次只有一个Goroutine进入临界区,从而保证对共享资源的有序访问。

package mainimport ("fmt""sync"
)var (sharedResource intmu             sync.Mutex
)func updateSharedResource() {mu.Lock()// Critical section: Access and modify sharedResourcesharedResource++mu.Unlock()
}func main() {var wg sync.WaitGroupfor i := 0; i < 100; i++ {wg.Add(1)go func() {defer wg.Done()updateSharedResource()}()}wg.Wait()fmt.Println("Shared Resource:", sharedResource)
}

在这个示例中,updateSharedResource 函数代表一个临界区,其中访问并修改了 sharedResource。如果没有使用互斥锁,对这个临界区的并发访问可能会导致不正确的结果。

互斥锁定

互斥锁提供了两个基本操作:锁定解锁。让我们首先了解互斥锁的锁定操作:

  • 锁定互斥锁:当一个Goroutine想要访问共享资源或一个临界区时,它会调用互斥锁上的Lock()方法。如果互斥锁当前是未锁定的,它将变为锁定状态,从而允许Goroutine继续执行。如果互斥锁已被另一个Goroutine锁定,调用的Goroutine将被阻塞,直到互斥锁变为可用状态。

下面是一个演示互斥锁锁定的代码示例:

package mainimport ("fmt""sync"
)func main() {var mu sync.Mutexmu.Lock() // Lock the Mutex// Critical section: Access and modify shared resourcefmt.Println("Locked the Mutex")mu.Unlock() // Unlock the Mutex
}

在这个示例中,mu.Lock() 调用锁定了互斥锁,确保一次只有一个Goroutine可以进入临界区。当完成临界区后,使用 mu.Unlock() 解锁互斥锁。

互斥锁解锁

  • 解锁互斥锁:当一个Goroutine完成其临界区的执行并且不再需要对共享资源进行独占访问时,它会在互斥锁上调用 Unlock() 方法。这个操作会释放互斥锁,从而允许其他Goroutines获取它。

以下是互斥锁解锁的执行方式:

package mainimport ("fmt""sync"
)func main() {var mu sync.Mutexmu.Lock() // Lock the Mutex// Critical section: Access and modify shared resourcefmt.Println("Locked the Mutex")mu.Unlock() // Unlock the Mutexfmt.Println("Unlocked the Mutex")
}

在这个示例中,在临界区之后调用了 mu.Unlock() 以释放互斥锁,使其可供其他Goroutines使用。

避免死锁

尽管互斥锁是确保并发安全性的强大工具,但如果使用不当,它们也可能引入死锁。死锁 是指两个或多个Goroutines被卡住,彼此等待释放资源的情况。为了避免死锁,请遵循以下最佳实践:

  1. 始终解锁:确保在锁定后解锁互斥锁。如果不这样做,可能会导致死锁。
  2. 使用 defer:为了确保互斥锁始终被解锁,考虑使用 defer 语句在函数结束时解锁它们。
  3. 避免循环依赖:小心循环依赖的情况,其中多个Goroutines互相等待释放资源。设计代码时要避免这种情况。
package mainimport ("fmt""sync"
)func main() {var mu sync.Mutexmu.Lock() // Lock the Mutex// Critical section: Access and modify shared resource// Oops! Forgot to unlock the Mutex// mu.Unlock() // Uncomment this line to avoid deadlockfmt.Println("Locked the Mutex")// ... Some more code// Potential deadlock if mu.Unlock() is not called
}

在这个示例中,如果遗忘或注释掉 mu.Unlock() 这一行,由于互斥锁持续保持锁定状态,可能会发生死锁。

1. 临界区

什么是临界区?

在并发编程中,临界区 是指访问共享资源或变量的代码部分。它被称为“临界”是因为在任何给定时刻只应允许一个Goroutine执行它。当多个Goroutines并发访问一个临界区时,可能会导致数据损坏或竞态条件,其中执行的顺序变得不可预测。

使用互斥锁保护临界区

互斥锁用于保护临界区,确保一次只有一个Goroutine可以访问它们。互斥锁提供了两个基本方法:

  • Lock(): 此方法锁定互斥锁,允许当前的Goroutine进入临界区。如果另一个Goroutine已经锁定了互斥锁,调用该方法的Goroutine将被阻塞,直到互斥锁被释放。
  • Unlock(): 此方法解锁互斥锁,允许其他Goroutines获取它并进入临界区。

以下是一个演示使用互斥锁保护临界区的示例:

package mainimport ("fmt""sync"
)var sharedResource int
var mu sync.Mutexfunc updateSharedResource() {mu.Lock() // Lock the Mutex// Critical section: Access and modify sharedResourcesharedResource++mu.Unlock() // Unlock the Mutex
}func main() {var wg sync.WaitGroupfor i := 0; i < 100; i++ {wg.Add(1)go func() {defer wg.Done()updateSharedResource()}()}wg.Wait()fmt.Println("Shared Resource:", sharedResource)
}

在这个示例中,updateSharedResource 函数代表一个临界区,其中 sharedResource 被访问和修改。互斥锁 mu 确保一次只有一个Goroutine可以进入这个临界区。

2. 互斥锁与通道的比较

互斥锁并不是Go中管理并发的唯一工具;通道也是另一个重要的机制。以下是互斥锁和通道的简要比较:

  • 互斥锁 用于保护临界区并确保对共享资源的独占访问。当您需要对数据访问进行细粒度的控制时,它们非常适用。
  • 通道 用于Goroutines之间的通信和同步。它们为交换数据和同步Goroutines提供了更高级别的抽象。

选择使用互斥锁还是通道取决于您程序的具体需求。当您需要保护共享数据时,互斥锁是理想的选择,而当通信和Goroutines之间的协调是主要关注点时,通道则表现出色。

总之,互斥锁是Go中确保安全并发的强大工具。它们有助于保护临界区,防止数据竞态,并确保共享资源的完整性。理解何时以及如何使用互斥锁对于编写既高效又可靠的并发Go程序至关重要。

这篇关于使用互斥锁(Mutex)管理共享资源的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/529947

相关文章

中文分词jieba库的使用与实景应用(一)

知识星球:https://articles.zsxq.com/id_fxvgc803qmr2.html 目录 一.定义: 精确模式(默认模式): 全模式: 搜索引擎模式: paddle 模式(基于深度学习的分词模式): 二 自定义词典 三.文本解析   调整词出现的频率 四. 关键词提取 A. 基于TF-IDF算法的关键词提取 B. 基于TextRank算法的关键词提取

使用SecondaryNameNode恢复NameNode的数据

1)需求: NameNode进程挂了并且存储的数据也丢失了,如何恢复NameNode 此种方式恢复的数据可能存在小部分数据的丢失。 2)故障模拟 (1)kill -9 NameNode进程 [lytfly@hadoop102 current]$ kill -9 19886 (2)删除NameNode存储的数据(/opt/module/hadoop-3.1.4/data/tmp/dfs/na

Hadoop数据压缩使用介绍

一、压缩原则 (1)运算密集型的Job,少用压缩 (2)IO密集型的Job,多用压缩 二、压缩算法比较 三、压缩位置选择 四、压缩参数配置 1)为了支持多种压缩/解压缩算法,Hadoop引入了编码/解码器 2)要在Hadoop中启用压缩,可以配置如下参数

Makefile简明使用教程

文章目录 规则makefile文件的基本语法:加在命令前的特殊符号:.PHONY伪目标: Makefilev1 直观写法v2 加上中间过程v3 伪目标v4 变量 make 选项-f-n-C Make 是一种流行的构建工具,常用于将源代码转换成可执行文件或者其他形式的输出文件(如库文件、文档等)。Make 可以自动化地执行编译、链接等一系列操作。 规则 makefile文件

使用opencv优化图片(画面变清晰)

文章目录 需求影响照片清晰度的因素 实现降噪测试代码 锐化空间锐化Unsharp Masking频率域锐化对比测试 对比度增强常用算法对比测试 需求 对图像进行优化,使其看起来更清晰,同时保持尺寸不变,通常涉及到图像处理技术如锐化、降噪、对比度增强等 影响照片清晰度的因素 影响照片清晰度的因素有很多,主要可以从以下几个方面来分析 1. 拍摄设备 相机传感器:相机传

综合安防管理平台LntonAIServer视频监控汇聚抖动检测算法优势

LntonAIServer视频质量诊断功能中的抖动检测是一个专门针对视频稳定性进行分析的功能。抖动通常是指视频帧之间的不必要运动,这种运动可能是由于摄像机的移动、传输中的错误或编解码问题导致的。抖动检测对于确保视频内容的平滑性和观看体验至关重要。 优势 1. 提高图像质量 - 清晰度提升:减少抖动,提高图像的清晰度和细节表现力,使得监控画面更加真实可信。 - 细节增强:在低光条件下,抖

pdfmake生成pdf的使用

实际项目中有时会有根据填写的表单数据或者其他格式的数据,将数据自动填充到pdf文件中根据固定模板生成pdf文件的需求 文章目录 利用pdfmake生成pdf文件1.下载安装pdfmake第三方包2.封装生成pdf文件的共用配置3.生成pdf文件的文件模板内容4.调用方法生成pdf 利用pdfmake生成pdf文件 1.下载安装pdfmake第三方包 npm i pdfma

零基础学习Redis(10) -- zset类型命令使用

zset是有序集合,内部除了存储元素外,还会存储一个score,存储在zset中的元素会按照score的大小升序排列,不同元素的score可以重复,score相同的元素会按照元素的字典序排列。 1. zset常用命令 1.1 zadd  zadd key [NX | XX] [GT | LT]   [CH] [INCR] score member [score member ...]

软考系统规划与管理师考试证书含金量高吗?

2024年软考系统规划与管理师考试报名时间节点: 报名时间:2024年上半年软考将于3月中旬陆续开始报名 考试时间:上半年5月25日到28日,下半年11月9日到12日 分数线:所有科目成绩均须达到45分以上(包括45分)方可通过考试 成绩查询:可在“中国计算机技术职业资格网”上查询软考成绩 出成绩时间:预计在11月左右 证书领取时间:一般在考试成绩公布后3~4个月,各地领取时间有所不同

git使用的说明总结

Git使用说明 下载安装(下载地址) macOS: Git - Downloading macOS Windows: Git - Downloading Windows Linux/Unix: Git (git-scm.com) 创建新仓库 本地创建新仓库:创建新文件夹,进入文件夹目录,执行指令 git init ,用以创建新的git 克隆仓库 执行指令用以创建一个本地仓库的