Go协程及并发锁应用指南

概念

协程(Goroutine)是Go语言独有的并发体,是一种轻量级的线程,也被称为用户态线程。相对于传统的多线程编程,协程的优点在于更加轻量级,占用系统资源更少,切换上下文的速度更快,不需要像多线程编程一样处理锁等线程安全问题。
在这里插入图片描述

1. 协程的创建

在Go语言中,可以使用go语句来启动一个协程。go语句后面跟的是一个函数调用,即启动一个新协程去执行该函数。例如:

func main() {go printHello() // 启动一个goroutine去执行printHello函数fmt.Println("main function")
}func printHello() {fmt.Println("hello goroutine")
}

在上面的代码中,printHello函数会在新的协程中执行,而不会阻塞主线程。

一、协程间的通信

在这里插入图片描述

1. Channel的定义和初始化

在Go语言中,协程之间的通信主要通过channel实现。使用make函数可以创建一个channel,其语法为:

channel_name := make(chan data_type)

其中,data_type为channel中传输数据的类型。例如,创建一个传输int类型数据的channel:

ch := make(chan int)
2. Channel的读写

Channel既可以进行发送操作,也可以进行接收操作。发送操作和接收操作都是阻塞的。

  • 发送操作:channel_name <- value
  • 接收操作:value := <-channel_name

二、并发锁的应用

在并发编程中,为了防止多个协程同时访问共享资源导致的数据竞争和不一致问题,需要使用锁机制来同步访问。Go语言提供了多种锁机制,包括互斥锁(Mutex)和读写锁(RWMutex)等。
在这里插入图片描述

1. 互斥锁(Mutex)

互斥锁是Go语言中最常用的锁机制,它确保同一时刻只有一个协程可以访问临界区。使用sync包中的Mutex类型来创建互斥锁,并通过Lock()Unlock()方法来加锁和解锁。

import "sync"var mutex = &sync.Mutex{}func criticalSection() {mutex.Lock()defer mutex.Unlock()// 临界区代码
}
2. 读写锁(RWMutex)

读写锁允许多个协程同时读取共享资源,但在有写操作时,需要互斥访问。使用sync包中的RWMutex类型来创建读写锁,通过RLock()RUnlock()Lock()Unlock()方法来分别获取读锁、释放读锁、获取写锁和释放写锁。

import "sync"var rwlock = &sync.RWMutex{}func read() {rwlock.RLock()defer rwlock.RUnlock()// 读取共享资源
}func write() {rwlock.Lock()defer rwlock.Unlock()// 修改共享资源
}

三、注意事项

  1. 锁的粒度:应尽可能减少锁的持有时间,避免降低程序的性能。
  2. 避免死锁:在使用锁时,需要仔细设计锁的使用顺序,避免循环等待导致的死锁。
  3. 选择合适的锁:根据具体场景选择合适的锁机制,如读写锁在读多写少的场景下可以显著提高性能。

在这里插入图片描述

四、简单完整示例

当然,以下是一个包含Go协程、Channel以及互斥锁(Mutex)完整示例的程序。这个程序将演示如何使用协程来处理并发任务,并通过Channel进行协程间的通信,同时使用互斥锁来保护共享资源的数据一致性。

package mainimport ("fmt""sync""time"
)// 假设有一个共享资源,我们需要保护它不被并发访问破坏
var (sharedResource intmutex          sync.Mutex
)// 一个用于修改共享资源的函数,通过互斥锁保证数据一致性
func modifySharedResource(increment int) {mutex.Lock()defer mutex.Unlock()sharedResource += incrementfmt.Printf("Modified sharedResource to %d\n", sharedResource)
}// 一个使用协程的函数,它会多次修改共享资源并通过Channel发送完成信号
func worker(done chan bool, increment int) {for i := 0; i < 5; i++ {modifySharedResource(increment)time.Sleep(time.Millisecond * 100) // 模拟耗时操作}done <- true // 发送完成信号
}func main() {done := make(chan bool, 2) // 创建一个带有缓冲的Channel,确保可以发送两个值而不会阻塞// 启动两个协程,每个协程都将尝试修改共享资源go worker(done, 10)go worker(done, 20)// 等待两个协程完成for i := 0; i < 2; i++ {<-done // 阻塞等待接收来自协程的完成信号}fmt.Println("All workers done. Final sharedResource:", sharedResource)
}

在这个示例中:

  1. 定义了一个全局的共享资源sharedResource和一个互斥锁mutex
  2. modifySharedResource函数用于修改共享资源,它首先加锁,修改完成后释放锁。
  3. worker函数是并发执行的函数,它接受一个done Channel和一个increment值作为参数。它会循环5次,每次循环都调用modifySharedResource来修改共享资源,并在每次修改后短暂睡眠以模拟耗时操作。循环结束后,它通过done Channel发送一个完成信号。
  4. main函数中,我们创建了一个done Channel和两个协程,每个协程以不同的increment值调用worker函数。
  5. 我们通过for循环和<-donedone Channel接收两次完成信号,确保两个协程都已完成工作。
  6. 最后,我们打印出最终的sharedResource值。

五、模拟错误收集示例

在Go语言中,协程(Goroutine)的错误处理通常是通过返回值、通道(Channel)或上下文(Context)来完成的。由于协程本质上是轻量级的线程,它们并不直接支持像传统线程那样的异常机制。不过,我们可以通过上述几种方式来实现错误传播和处理。

下面是一个扩展了之前示例的程序,其中增加了协程的错误处理。我们将使用通道(Channel)来传递错误和完成信号。

package mainimport ("errors""fmt""sync""time"
)// 假设的共享资源
var sharedResource int
var mutex sync.Mutex// 模拟可能失败的操作
func modifySharedResource(increment int) error {mutex.Lock()defer mutex.Unlock()// 假设某种条件下操作失败if increment < 0 {return errors.New("negative increment is not allowed")}sharedResource += incrementfmt.Printf("Modified sharedResource to %d\n", sharedResource)return nil
}// worker 协程函数,现在可以返回错误
func worker(done chan bool, errChan chan error, increment int) {for i := 0; i < 5; i++ {if err := modifySharedResource(increment); err != nil {errChan <- err // 将错误发送到错误通道return}time.Sleep(time.Millisecond * 100) // 模拟耗时操作}done <- true // 发送完成信号
}func main() {done := make(chan bool, 2)errChan := make(chan error, 2) // 创建一个用于传递错误的通道// 启动两个协程,一个可能遇到错误go worker(done, errChan, 10)go worker(done, errChan, -5)  // 这个将尝试一个负增量,应该失败// 等待协程完成或接收错误for i := 0; i < 2; i++ {select {case <-done:fmt.Println("Worker done")case err := <-errChan:fmt.Println("Error received:", err)// 根据需要处理错误,比如退出程序、记录日志等// 这里我们简单地打印错误并继续等待其他协程}}// 注意:在实际情况中,你可能需要一种方式来确保所有协程都已完成或都已报告错误// 这里为了简化,我们没有实现这样的逻辑fmt.Println("All workers potentially done or errors reported. Final sharedResource:", sharedResource)// 注意:如果某些协程可能永远不发送完成信号(比如因为死循环或无限等待),// 你可能需要一个超时机制或一种方式来优雅地关闭这些协程。
}

在这个示例中:

  • modifySharedResource 函数现在可以返回一个错误,如果增量是负数。
  • worker 函数现在接受一个额外的 errChan 通道,用于在发生错误时发送错误消息。如果发生错误,worker 函数将发送错误并立即返回。
  • main 函数中,我们使用了一个 select 语句来同时等待完成信号和错误。这允许我们在任何一个事件发生时都能立即响应。

请注意:这个示例并没有实现一个完美的错误处理策略,特别是如果某些协程可能永远不发送完成信号(比如因为死循环或无限等待)。在实际应用中,你可能需要实现更复杂的逻辑来确保程序的健壮性和可靠性。例如,你可以使用上下文(Context)来优雅地关闭或取消长时间运行的协程。

六、举一个实际应用的示例[更新购物车数量]

  1. 高效并发处理:购物车系统在高并发访问时,需要快速处理多个用户的请求。Go协程的轻量级特性使得能够轻松创建成千上万的并发任务,而不会对系统资源造成太大压力。

  2. 简化并发编程:Go的协程和通道(Channel)模型简化了并发编程的复杂度。通过通道进行协程间的通信,可以避免传统并发编程中的许多常见问题,如竞态条件、死锁等。

  3. 内置并发原语:Go标准库提供了丰富的并发原语,如互斥锁(Mutex)、读写锁(RWMutex)、条件变量(Cond)等,这些工具可以进一步帮助开发者编写安全、高效的并发代码。

  4. 易于调试和监控:Go的协程模型使得并发程序的调试和监控相对容易。通过工具如pproftrace等,开发者可以很方便地分析并发程序的性能瓶颈和潜在问题。

购物车并发处理完整示例

下面是一个简化的购物车并发处理示例,展示了如何使用Go协程和通道来处理多个用户的购物车更新请求。

package mainimport ("fmt""sync""time"
)// 假设的购物车结构
type ShoppingCart struct {Items map[string]intmutex sync.Mutex
}// 更新购物车的函数
func (c *ShoppingCart) Update(itemID string, quantity int) {c.mutex.Lock()defer c.mutex.Unlock()c.Items[itemID] += quantityfmt.Printf("Updated cart, item %s now has %d\n", itemID, c.Items[itemID])
}// 模拟处理购物车更新请求的协程
func handleCartUpdate(cart *ShoppingCart, itemID string, quantity int, done chan<- bool) {time.Sleep(time.Millisecond * 100) // 模拟处理时间cart.Update(itemID, quantity)done <- true // 发送完成信号
}func main() {cart := &ShoppingCart{Items: make(map[string]int)}done := make(chan bool, 10) // 假设最多同时处理10个请求// 模拟多个用户同时更新购物车for i := 0; i < 10; i++ {go handleCartUpdate(cart, fmt.Sprintf("item%d", i), 5, done)}// 等待所有更新完成for i := 0; i < 10; i++ {<-done}fmt.Println("All cart updates completed.")// 在这里可以进一步处理更新后的购物车,如发送到数据库保存等
}

在这个示例中:

  • 我们定义了一个ShoppingCart结构体,它包含一个商品项的映射和一个互斥锁来保护这个映射的并发访问。
  • Update方法用于更新购物车中的商品数量,它通过互斥锁来确保线程安全。
  • handleCartUpdate协程函数模拟了处理购物车更新请求的过程,它接收购物车、商品ID、数量和完成信号通道作为参数,并在更新完成后发送完成信号。
  • main函数中,我们创建了10个协程来模拟多个用户同时更新购物车的情况,并通过done通道等待所有更新完成。

请注意:这个示例为了简化而省略了一些重要的错误处理和优化措施,比如在实际应用中你可能需要处理网络请求、数据库操作等可能失败的情况,并且可能需要使用更复杂的并发控制策略来优化性能。

总结

通过以上指南,您可以更好地理解和应用Go协程及并发锁,在Go语言的并发编程中编写出高效、安全的代码。以上都是些简单代码片段示例,不能作为实际应用使用哦。

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

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

相关文章

ClickHouse的安装配置+DBeaver远程连接

1、clickhouse的下载&#xff1a; 先去clickhouse官网进行下载&#xff0c;继续往下翻找文档&#xff0c;将DBeaver也下载下来 下载地址&#xff1a;https://packages.clickhouse.com/rpm/stable/ 下载这个四个rpm包 2、上传rmp文件到Linux中 自己创建的一个clickhouse-ins…

ceph简介

ceph存储简要概述&#xff1a; 通过将文件分解成固定大小对象&#xff0c;然后存放于pool中&#xff0c;每个pool中 可包含多个pg&#xff0c;每个pg中又可包含多个osd 通过crush算法 最终数据落盘到osd中去。 一、ceph 删除osd 步骤1 修改osd数据操作权重值 ceph osd crush r…

【Qt】解决设置QPlainTextEdit控件的Tab为4个空格

前言 PyQt5 是一个用于创建跨平台桌面应用程序的 Python 绑定集合&#xff0c;它提供了对 Qt 应用程序框架的访问。用于开发具有图形用户界面&#xff08;GUI&#xff09;的应用程序&#xff0c;以及非GUI程序。PyQt5 使得 Python 开发者可以使用 Qt 的丰富功能来构建应用程序。…

kubernetes微服务基础及类型

目录 1 什么是微服务 2 微服务的类型 3 ipvs模式 ipvs模式配置方式 4 微服务类型详解 4.1 ClusterIP 4.2 ClusterIP中的特殊模式headless 4.3 nodeport 4.4 metalLB配合loadbalance实现发布IP 1 什么是微服务 用控制器来完成集群的工作负载&#xff0c;那么应用如何暴漏出去&…

PHP悦读随行一键借阅图书小程序

悦读随行&#xff1a;一键借阅图书馆小程序&#xff0c;让阅读与你同行 &#x1f4da; 封面&#xff1a;解锁阅读新方式 在这个信息爆炸的时代&#xff0c;我们总在寻找更高效、更便捷的方式来获取知识。今天&#xff0c;就让我们一起探索“悦读随行一键借阅图书馆小程序”&am…

shell脚本语法

shell脚本的变量 系统变量 系统变量是操作系统用来存储配置信息的变量&#xff0c;它们可以控制操作系统的行为和程序的运行环境。系统变量的种类和内容取决于操作系统的类型和版本。以下是一些常见的系统变量类别和它们可能包含的内容&#xff1a; 环境变量&#xff1a;这些…

深度学习-神经网络

文章目录 一、基本组成单元&#xff1a;神经元二、神经网络层三、偏置与权重四、激活函数1.激活函数的作用2.常见的激活函数1).Sigmoid2).Tanh函数3).ReLU函数 五、优点与缺点六、总结 神经网络&#xff08;Neural Network, NN&#xff09;是一种模拟人类大脑工作方式的计算模型…

0基础跟德姆(dom)一起学AI 数据处理和统计分析02-Linux进阶

* vi编辑器 * 权限相关 * 进程,网络相关 * 压缩和解压缩 * 软件安装-yum方式 * 其它命令 --- 1.过滤和管道命令 shell # grep命令, 用来过滤的 # 格式 grep [-n] 关键字 文件路径 # 从文件中过滤出要查找的内容, -n:表示带行号. # | 管道符, 即: 把前边命令的执行结果,…

QT程序的安装包制作教程

在Windows平台上开发完qt c桌面应用程序以后&#xff0c;需要制作一个安装包&#xff0c;方便生产和刻盘交货&#xff0c;本文记录相关流程。 目录 一、安装Qt Installer Framework 二、准备可执行程序 2.1 生成Release程序 2.2 完成依赖库拷贝 三、创建安装包程序 一、…

C到C++入门基础知识

一&#xff1a;命名空间&#xff1a;namespace &#xff08;一&#xff09;&#xff1a;命名空间的定义 注&#xff1a;命名空间只能定义在全局&#xff0c;不能定义在函数内部。 &#xff08;1&#xff09;类似于C语言的结构体&#xff0c;C语言的命名空间定义为&#xff1…

在 Mac 上安装虚拟机怎么样,安装虚拟机与直接安装 Windows 系统有区别吗?

随着跨系统操作的不断发展&#xff0c;虚拟机技术在生产力领域扮演着越来越重要的角色。Mac作为一款主流的操作系统&#xff0c;也有着运行虚拟机的能力。接下来给大家介绍Mac装虚拟机好不好&#xff0c;Mac装虚拟机和装Windows系统一样吗的具体内容。 Mac装虚拟机好不好 Mac…

大屏地图区域显示、复选框多选打点,自定义窗体信息(vue3+TS)

效果图&#xff1a; NPM 安装 Loader&#xff1a; npm i amap/amap-jsapi-loader --save 并设置 key 和安全密钥&#xff1a; import AMapLoader from amap/amap-jsapi-loader;//引入高德地图window._AMapSecurityConfig {securityJsCode: "「你申请的安全密钥」"…

基于YOLO深度学习和百度AI接口的手势识别与控制项目

基于YOLO深度学习和百度AI接口的手势识别与控制项目 项目描述 本项目旨在开发一个手势识别与控制系统&#xff0c;该系统能够通过摄像头捕捉用户的手势&#xff0c;并通过YOLO深度学习模型或调用百度AI接口进行手势识别。识别到的手势可以用来控制计算机界面的操作&#xff0…

单机docker-compose部署minio

单机多副本docker-compose部署minio 简单介绍 如果服务器有限可以单机挂载多硬盘实现多副本容错&#xff08;生产不推荐&#xff09; 部署好的文件状态 有两个重要文件 docker-compose.yaml和nginx.conf docker-compose.yaml是docker部署容器的配置信息包括4个minio和1个ng…

[数据集][目标检测]男女性别检测数据集VOC+YOLO格式9769张2类别

数据集格式&#xff1a;Pascal VOC格式YOLO格式(不包含分割路径的txt文件&#xff0c;仅仅包含jpg图片以及对应的VOC格式xml文件和yolo格式txt文件) 图片数量(jpg文件个数)&#xff1a;9769 标注数量(xml文件个数)&#xff1a;9769 标注数量(txt文件个数)&#xff1a;9769 标注…

Miracast/WifiDisplay开发相关的深入调研分析-android投屏实战开发

Miracast/WifiDisplay概念介绍 Miracast Miracast是由Wi-Fi联盟于2012年所制定&#xff0c;以Wi-Fi直连&#xff08;Wi-Fi Direct&#xff09;为基础的无线显示标准。支持此标准的消费性电子产品&#xff08;又称3C设备&#xff09;可透过无线方式分享视频画面&#xff0c;例如…

CSS学习17--CSS3 过渡、2D变形、3D变形、动画

CSS3 过渡、2D变形、3D变形、动画 一、过渡二、2D变形 transform1.移动 translate2.缩放 scale3. 旋转 rotate4. 倾斜 skew 三、3D变形1. rotateX&#xff08;&#xff09;rotateY&#xff08;&#xff09; rotateZ&#xff08;&#xff09;2. 体会透视 perspective3. translat…

虚拟现实智能家居实训系统实训解决方案

随着科技的飞速发展&#xff0c;智能家居已成为现代生活的重要组成部分&#xff0c;它不仅极大地提升了居住的便捷性与舒适度&#xff0c;还推动了物联网、大数据、人工智能等前沿技术的融合应用。为了满足市场对智能家居专业人才日益增长的需求&#xff0c;虚拟现实智能家居实…

搭建 WordPress 及常见问题与解决办法

浪浪云活动链接 &#xff1a;https://langlangy.cn/?i8afa52 文章目录 环境准备安装 LAMP 堆栈 (Linux, Apache, MySQL, PHP)配置 MySQL 数据库 安装 WordPress配置 WordPress常见问题及解决办法数据库连接错误白屏问题插件或主题冲突内存限制错误 本文旨在介绍如何在服务器上…

Linux下vscode配置C++和python编译调试环境

Visual Studio Code (简称 VSCode) 是由微软开发的一款免费、开源、跨平台的代码编辑器。它支持 Windows、macOS 和 Linux 操作系统&#xff0c;并且内置对多种编程语言的支持&#xff0c;包括但不限于 C/C、Python、JavaScript、TypeScript、Java 和 Go 等。VSCode 主要用于编…