掌握Go语言:Go语言通道,并发编程的利器与应用实例(20)

通道(Channel)是用来在 Go 程序中传递数据的一种数据结构。它是一种类型安全的、并发安全的、阻塞式的数据传输方式,用于在不同的 Go 协程之间传递消息。

基本概念

  • 创建通道:使用make()函数创建一个通道。
ch := make(chan int) // 创建一个整型通道
  • 发送数据:使用<-操作符向通道发送数据。
ch <- 42 // 将整数42发送到通道ch中
  • 接收数据:使用<-操作符从通道接收数据。
x := <-ch // 从通道ch中接收数据并赋值给变量x
  • 关闭通道:使用close()函数关闭一个通道。
close(ch) // 关闭通道ch

应用场景

通道在 Go 语言中的应用非常广泛,常见的应用场景包括:

  1. 协程间通信:在不同的 Go 协程之间传递数据。
  2. 控制并发:使用通道来控制并发执行的数量,避免资源竞争。
  3. 数据传输:用于在不同协程之间传输数据,例如从生产者协程发送数据到消费者协程。

示例:

package mainimport "fmt"func main() {// 创建一个整型通道ch := make(chan int)// 启动一个协程发送数据到通道go func() {ch <- 42 // 发送整数42到通道}()// 从通道接收数据并打印fmt.Println(<-ch) // 输出:42
}

Go语言通道并发编程

在Go语言中,通道广泛应用于并发编程,用于在不同的协程之间安全地传递数据。

并发安全性:

  • 同步操作:通道上的发送和接收操作是原子性的,保证了数据的一致性和可靠性。
  • 阻塞机制:当通道为空时,接收操作会阻塞等待数据;当通道满时,发送操作会阻塞等待空间。

示例:

package mainimport ("fmt""time"
)func main() {ch := make(chan int) // 创建一个整型通道// 启动一个协程发送数据到通道go func() {for i := 0; i < 5; i++ {ch <- i // 发送整数到通道time.Sleep(time.Second) // 模拟耗时操作}close(ch) // 关闭通道}()// 从通道接收数据并打印for num := range ch {fmt.Println("Received:", num)}
}

并发编程示例:

package mainimport ("fmt""sync"
)func main() {ch := make(chan int) // 创建一个整型通道var wg sync.WaitGroup// 启动3个协程向通道发送数据for i := 0; i < 3; i++ {wg.Add(1)go func(id int) {defer wg.Done()for j := 0; j < 5; j++ {ch <- id*10 + j // 发送数据到通道}}(i)}// 启动一个协程从通道接收数据go func() {wg.Wait()close(ch)}()// 从通道接收数据并打印for num := range ch {fmt.Println("Received:", num)}
}

上面这段代码演示了使用通道在 Go 语言中进行并发编程的示例。让我们逐步解释它:

  1. 导入包

    import ("fmt""sync"
    )
    

    导入了 fmtsync 包。fmt 包用于格式化输出,sync 包提供了同步功能,其中 sync.WaitGroup 类型用于等待一组协程执行完毕。

  2. main 函数

    func main() {// 创建一个整型通道ch := make(chan int)// 创建一个等待组var wg sync.WaitGroup
    

    main 函数中,首先创建了一个整型通道 ch,用于协程之间的数据传输。然后创建了一个 sync.WaitGroup 类型的变量 wg,用于等待所有协程执行完毕。

  3. 启动协程发送数据

        for i := 0; i < 3; i++ {wg.Add(1) // 增加等待组计数go func(id int) {defer wg.Done() // 协程执行完毕时减少等待组计数for j := 0; j < 5; j++ {ch <- id*10 + j // 发送数据到通道}}(i) // 使用闭包保证每个协程的id不同}
    

    这段代码启动了 3 个协程,每个协程都会向通道 ch 中发送一系列整数。在每个协程内部,wg.Add(1) 用于增加等待组的计数,表示有一个新的协程加入;defer wg.Done() 则表示协程执行完毕时减少等待组的计数,使用 defer 关键字确保在函数退出时执行。每个协程会循环 5 次,每次发送一个整数到通道 ch 中,整数的值为协程的 id 乘以 10 再加上循环变量 j

  4. 启动协程接收数据

        go func() {wg.Wait() // 等待所有协程执行完毕close(ch) // 关闭通道}()
    

    在这里,启动了一个新的协程,用于等待所有的发送协程执行完毕,并在等待完成后关闭通道 chwg.Wait() 会阻塞,直到所有协程执行完毕。

  5. 从通道接收数据并打印

        for num := range ch {fmt.Println("Received:", num)}
    

    最后,使用 range 关键字从通道 ch 中循环接收数据,并将接收到的数据打印出来。由于通道已经在发送协程执行完毕后关闭了,因此在所有数据都被接收完毕后,range 循环会自动结束。

这样,该程序就完成了在多个协程之间安全地发送和接收数据的任务,展示了 Go 语言中使用通道进行并发编程的基本方法。

进销存通道并发实例

在一个进销存系统中,通道可以用于并发处理订单和库存的管理。下面是一个简化的示例,展示了如何使用通道来处理订单和库存的并发操作:

package mainimport ("fmt""time"
)type Order struct {ID       intQuantity int
}func processOrders(orders <-chan Order, stock chan<- int) {for order := range orders {// 模拟处理订单的过程fmt.Printf("Processing order %d...\n", order.ID)time.Sleep(2 * time.Second) // 模拟处理订单所需的时间// 减少库存量stock <- order.Quantity}close(stock)
}func main() {orders := make(chan Order)stock := make(chan int)// 启动一个协程来处理订单go processOrders(orders, stock)// 模拟订单生成go func() {for i := 1; i <= 5; i++ {order := Order{ID: i, Quantity: 1}orders <- orderfmt.Printf("Order %d placed.\n", i)}close(orders)}()// 更新库存totalStock := 10for quantity := range stock {totalStock -= quantityfmt.Printf("Stock updated. Remaining: %d\n", totalStock)}fmt.Println("All orders processed.")
}

这段代码演示了一个简单的进销存系统,其中使用了 Go 语言中的通道来处理订单和更新库存。

  1. 定义订单结构体
type Order struct {ID       int // 订单IDQuantity int // 订单数量
}

订单结构体包含订单的 ID 和数量。

  1. 处理订单的函数
func processOrders(orders <-chan Order, stock chan<- int) {for order := range orders {fmt.Printf("Processing order %d...\n", order.ID)time.Sleep(2 * time.Second) // 模拟处理订单所需的时间stock <- order.Quantity      // 将订单中的数量发送到库存通道}close(stock) // 关闭库存通道
}

processOrders 函数接收两个通道作为参数:orders 通道用于接收订单,stock 通道用于发送库存更新信息。函数从 orders 通道中循环接收订单,模拟处理订单的过程,并将订单中的数量发送到 stock 通道中。

  1. 主函数
func main() {orders := make(chan Order) // 创建订单通道stock := make(chan int)    // 创建库存通道// 启动一个协程来处理订单go processOrders(orders, stock)// 模拟订单生成go func() {for i := 1; i <= 5; i++ {order := Order{ID: i, Quantity: 1}orders <- orderfmt.Printf("Order %d placed.\n", i)}close(orders) // 关闭订单通道}()// 更新库存totalStock := 10 // 初始库存量for quantity := range stock {totalStock -= quantityfmt.Printf("Stock updated. Remaining: %d\n", totalStock)}fmt.Println("All orders processed.")
}

main 函数中,我们创建了订单通道 orders 和库存通道 stock。然后启动了一个协程来处理订单,使用匿名函数模拟订单生成过程,并将订单发送到 orders 通道中。接着,在主函数中从 stock 通道中接收库存更新信息,并更新库存量。当所有订单处理完毕后,程序输出 “All orders processed.”。

通过使用通道,可以实现订单的并发处理和库存的实时更新,提高系统的效率和响应速度。

Go语言通道的注意事项

注意事项:

  1. 避免死锁:当发送和接收操作的数量不匹配时,可能会发生死锁。例如,发送者发送数据到已经关闭的通道,或者接收者从空通道接收数据。

示例:

package mainimport "fmt"func main() {ch := make(chan int) // 创建一个整型通道close(ch)            // 关闭通道// 发送数据到已关闭的通道会导致panicch <- 42
}
  1. 通道的阻塞:当通道为空时,接收操作会阻塞等待数据;当通道满时,发送操作会阻塞等待空间。

示例:

package mainimport "fmt"func main() {ch := make(chan int, 1) // 创建一个容量为1的整型通道ch <- 42 // 发送数据到通道ch <- 43 // 发送第二个数据到通道,因为通道已满,会导致阻塞fmt.Println("Data sent to channel")
}

总结

Go语言的通道是一种简单、高效的并发编程模型,提供了安全的数据传递和同步机制。通过通道,可以方便地实现不同 goroutine 之间的数据交流和协作,避免了共享数据的竞争和锁的复杂性。在并发编程中,通道是一种重要的组件,可以大大简化并发编程的复杂性,提高程序的可读性和可维护性。

通过了解通道的基本操作和特性,并结合实际场景,可以更好地应用通道来实现并发编程,提高程序的性能和稳定性。同时,需要注意避免常见的问题,如死锁和通道的关闭,以确保程序的正确性和健壮性。

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

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

相关文章

【spring】@Conditional注解学习

Conditional介绍 Conditional注解用于按照设定的条件进行判断&#xff0c;从而决定是否将某个bean注册到Spring容器中。 Conditional注解是在Spring 4.0版本中引入的&#xff0c;它提供了一种更加灵活的方式来控制bean的创建和注册。在此之前&#xff0c;开发者通常使用Profi…

Automated and Cooperative Vehicle Merging at Highway On-Ramps

论文解读——Automated and Cooperative Vehicle Merging at Highway On-Ramps 参考资料来源&#xff1a;《Automated and Cooperative Vehicle Merging at Highway On-Ramps》一文 1.问题描述 该文章想解决如FIG.1中的匝道合流问题&#xff0c;传统的匝道合理需要等待main r…

vue@2.7.16 使用less、less-loader

遇到问题&#xff0c;npm install less-loader7.3.0 --save安装好less-loader后&#xff0c;执行npm run serve 项目运行不起来&#xff0c;排查后发现在安装less-loader后就提示需要安装less&#xff0c;正确的安装应如下&#xff1a; npm install less less-loader7.3.0 --sa…

物联网应用技术中的stm32该怎么学,该从哪入手?

物联网应用技术中的stm32该怎么学&#xff0c;该从哪入手&#xff1f; STM32是只物联网中的一部分&#xff0c;单纯的学个STM32是没法满足物联网开发需求的&#xff0c;实际产品开发过程中会考虑成本等多种因素选择合适的方案&#xff0c;比如使用单片机还是stm32或是更高端的芯…

前端vue实现甘特图

1 什么是甘特图 甘特图(Gantt chart)又称为横道图、条状图(Bar chart)。以提出者亨利L甘特先生的名字命名&#xff0c;是项目管理、生产排程、节点管理中非常常见的一个功能。 甘特图内在思想简单&#xff0c;即以图示的方式通过活动列表和时间刻度形象地表示出任何特定项目的…

將SqlServer表創建到hive腳本

將SqlServer表創建到hive腳本 sqlserver.java import java.util.ArrayList; import java.util.regex.Matcher; import java.util.regex.Pattern;public class sqlserver {private static String[] deleteArrayNull(String string[]) {ArrayList<String> strList new A…

考研数学|《660》题这样刷,效率最高!

首先要了解一下660的难度&#xff0c;我认为660的难度是在基础和强化之间的一本习题册。具有一些比较好的选填题目&#xff0c;有些题目可能对初学者来说较为困难&#xff0c;尤其是一些包含二级结论的一些题目。但是对于强化阶段来说&#xff0c;这本题目可能难度较低了一些。…

基于springboot+vue的游戏交易系统

博主主页&#xff1a;猫头鹰源码 博主简介&#xff1a;Java领域优质创作者、CSDN博客专家、阿里云专家博主、公司架构师、全网粉丝5万、专注Java技术领域和毕业设计项目实战&#xff0c;欢迎高校老师\讲师\同行交流合作 ​主要内容&#xff1a;毕业设计(Javaweb项目|小程序|Pyt…

如何设计一个订单超过5分钟不支付就自动去掉订的设计?都有哪些方案?

实现订单在超过5分钟不支付就自动取消的功能&#xff0c;可以通过多种方案来设计。以下是一些常见的解决方案&#xff1a; 定时任务&#xff08;Cron Job&#xff09;&#xff1a; 创建一个定时任务&#xff0c;定期扫描数据库中创建时间超过5分钟且未支付的订单&#xff0c;然…

C语言学习 三、运算符与表达式

3.1 运算符分类 c语言提供了13种类型的运算符&#xff0c;如下所示&#xff1a; &#xff08;1&#xff09;算术运算符&#xff08; - * / %&#xff09; &#xff08;2&#xff09;关系运算符&#xff08;> < > < !&#xff09; &#xff08;3&#xff09;逻…

【职位管理】某大型能源化工企业职位管理体系搭建咨询项目

随着企业的发展&#xff0c;企业内部员工的数量不断增加。而管理职位的有限性使得员工的晋升出现“过独木桥”的现象&#xff0c;有些企业为了缓解这种问题&#xff0c;采取增设副职与助理岗位的办法&#xff0c;却导致组织机构迅速膨胀。那么&#xff0c;华恒智信专家是如何解…

CentOS的变迁轨迹:企业代码迁移的深刻启示20240321

在企业的技术栈中&#xff0c;操作系统扮演着基础且关键的角色。CentOS&#xff0c;作为长久以来广受欢迎的企业级Linux发行版&#xff0c;其版本的迁移与升级一直是系统管理员和开发者们关注的焦点。最近&#xff0c;CentOS的发展趋势引起了广泛讨论&#xff0c;特别是CentOS …

在基于全志V851se的TinyVision上手动构建 Linux 6.1 + Debian 12 镜像

构建 SyterKit 作为 Bootloader SyterKit 是一个纯裸机框架&#xff0c;用于 TinyVision 或者其他 v851se/v851s/v851s3/v853 等芯片的开发板&#xff0c;SyterKit 使用 CMake 作为构建系统构建&#xff0c;支持多种应用与多种外设驱动。同时 SyterKit 也具有启动引导的功能&a…

JavaScript的导入导出

导入JavaScript的全部内容 <script src"JavaScriptName.js"></script>逐个导出 JS代码 export function getMessage(msg){console.log(msg) }HTML代码 <script type"module">import { getMessage } from ./showMessage.jsdocument.g…

mysql数据类型和常用函数

目录 1.整型 1.1参数signed和unsigned 1.2参数zerofill 1.3参数auto_increment 2.数字类型 2.1floor()向下取整 2.2随机函数rand() 2.3重复函数repeat() 3.字符串类型 3.1length()查看字节长度&#xff0c;char_length()查看字符长度 3.2字符集 3.2.1查看默认字符…

海外舆情监控的重要性以及云手机的推荐

海外市场不仅有着无尽的商机&#xff0c;同时也存在着各种各样的挑战。例如&#xff0c;海外市场舆情的复杂变化给企业带来了潜在风险&#xff0c;尤其在新媒体技术快速发展的时代&#xff0c;舆论对企业品牌形象的影响日益巨大。本文将详细探讨海外舆情监控的重要性以及为大家…

mysql日志( Redo Log 、Undo Log、Bin Log)

InnoDB是一个带有ACID事务支持的存储引擎&#xff0c;其中redo log和undo log是其实现原子性、一致性、隔离性和持久性&#xff08;ACID&#xff09;的重要机制。 Redo Log&#xff08;重做日志&#xff09; Redo log主要用于实现事务的持久性。它记录了后续可以用来恢复数据…

FlorisBoard:Android开源键盘的现代化选择

FlorisBoard&#xff1a;Android开源键盘的现代化选择 简介 FlorisBoard是一款免费且开源的安卓键盘&#xff0c;适用于Android 7.0及以上版本的设备。它的现代化设计和用户友好的界面使其在众多键盘应用中脱颖而出。FlorisBoard的独特之处在于它注重用户体验的同时&#xff0…

CSS object-fit 属性

object-fit 属性指定元素的内容应该如何去适应指定容器的高度与宽度。 object-fit 一般用于 img 和 video 标签&#xff0c;一般可以对这些元素进行保留原始比例的剪切、缩放或者直接进行拉伸等。 您可以通过使用 object-position 属性来切换被替换元素的内容对象在元素框内的…

使用java实现三个线程循环打印A,B,C,并写出三种方式

方式一&#xff1a;使用wait()和notifyAll() public class demo1 {private int n 0;private int turn 0;public static void main(String[] args) {new demo1().startThreads();}private void startThreads() {new Thread(() -> printLetter(A, 0), "线程1").s…