Golang 协程和 Channel 的协同工作

2024-06-02 09:04

本文主要是介绍Golang 协程和 Channel 的协同工作,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

在 Golang 中,协程(goroutine)和通道(channel)是并发编程的两大支柱。协程是一种轻量级的线程,而通道则是协程之间进行通信的管道。在本文中,我们将通过一个简单的示例来深入理解它们是如何协同工作的。

协程:Golang 并发的核心

Golang 的协程是一种非常高效的并发机制。与传统的线程相比,协程的创建和切换开销要小得多。在 Golang 中,协程是默认非阻塞的,这意味着当一个协程在等待另一个协程完成操作时,它不会占用 CPU 资源。

通道:协程间的通信桥梁

通道是 Golang 中用于在协程之间传递数据的一种类型。通道可以是有缓冲的,也可以是无缓冲的。无缓冲的通道在读写时都是阻塞的,这保证了数据的同步传递。当通道被关闭后,任何试图从该通道读取数据的操作都会立即返回,并且返回的值是通道元素类型的零值。

示例:生成并打印随机数

下面是一个使用协程和通道的示例代码,它演示了如何生成五个随机数,并将它们打印到标准输出。

package mainimport ("fmt""math/rand""sync""time"
)func main() {// 创建一个无缓冲的 channelout := make(chan int)// 创建一个 WaitGroup 用于等待两个协程完成var wg sync.WaitGroupwg.Add(2)// 第一个协程:生成随机数并发送到 channelgo func() {defer wg.Done()for i := 0; i < 5; i++ {// 生成随机数并发送到 channelout <- rand.Intn(100) // 这里我们生成 0 到 99 之间的随机数}// 发送完所有随机数后,关闭 channelclose(out)}()// 第二个协程:从 channel 中读取并打印随机数go func() {defer wg.Done()for num := range out {fmt.Println(num)}}()// 等待两个协程完成wg.Wait()
}

代码解析

  1. 创建通道:我们首先创建了一个无缓冲的整数类型通道 out

  2. 初始化 WaitGroupsync.WaitGroup 用于等待多个协程完成。我们添加了两个协程,所以调用了 wg.Add(2)

  3. 第一个协程:这个协程负责生成随机数。我们使用 rand.Intn(100) 生成 0 到 99 之间的随机整数,并将其发送到 out 通道。生成了五个随机数后,我们关闭了通道。

  4. 第二个协程:这个协程负责从 out 通道读取数据,并将其打印到标准输出。由于通道是无缓冲的,这个协程会阻塞,直到有数据可读。当通道关闭后,for 循环会退出。

  5. 等待协程完成:最后,我们调用 wg.Wait() 等待两个协程都完成执行。

总结

通过这个简单的示例,我们可以看到 Golang 协程和通道如何协同工作来实现并发操作。这种模式非常适合处理 I/O 密集型任务,如网络通信、文件读写等。理解并掌握协程和通道的使用,将帮助你编写出高效、简洁且易于维护的并发程序。

这篇关于Golang 协程和 Channel 的协同工作的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



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

相关文章

Android协程高级用法大全

《Android协程高级用法大全》这篇文章给大家介绍Android协程高级用法大全,本文结合实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友跟随小编一起学习吧... 目录1️⃣ 协程作用域(CoroutineScope)与生命周期绑定Activity/Fragment 中手

Go语言使用select监听多个channel的示例详解

《Go语言使用select监听多个channel的示例详解》本文将聚焦Go并发中的一个强力工具,select,这篇文章将通过实际案例学习如何优雅地监听多个Channel,实现多任务处理、超时控制和非阻... 目录一、前言:为什么要使用select二、实战目标三、案例代码:监听两个任务结果和超时四、运行示例五

全面解析Golang 中的 Gorilla CORS 中间件正确用法

《全面解析Golang中的GorillaCORS中间件正确用法》Golang中使用gorilla/mux路由器配合rs/cors中间件库可以优雅地解决这个问题,然而,很多人刚开始使用时会遇到配... 目录如何让 golang 中的 Gorilla CORS 中间件正确工作一、基础依赖二、错误用法(很多人一开

golang程序打包成脚本部署到Linux系统方式

《golang程序打包成脚本部署到Linux系统方式》Golang程序通过本地编译(设置GOOS为linux生成无后缀二进制文件),上传至Linux服务器后赋权执行,使用nohup命令实现后台运行,完... 目录本地编译golang程序上传Golang二进制文件到linux服务器总结本地编译Golang程序

Android kotlin中 Channel 和 Flow 的区别和选择使用场景分析

《Androidkotlin中Channel和Flow的区别和选择使用场景分析》Kotlin协程中,Flow是冷数据流,按需触发,适合响应式数据处理;Channel是热数据流,持续发送,支持... 目录一、基本概念界定FlowChannel二、核心特性对比数据生产触发条件生产与消费的关系背压处理机制生命周期

golang版本升级如何实现

《golang版本升级如何实现》:本文主要介绍golang版本升级如何实现问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录golanwww.chinasem.cng版本升级linux上golang版本升级删除golang旧版本安装golang最新版本总结gola

golang中reflect包的常用方法

《golang中reflect包的常用方法》Go反射reflect包提供类型和值方法,用于获取类型信息、访问字段、调用方法等,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值... 目录reflect包方法总结类型 (Type) 方法值 (Value) 方法reflect包方法总结

Golang如何对cron进行二次封装实现指定时间执行定时任务

《Golang如何对cron进行二次封装实现指定时间执行定时任务》:本文主要介绍Golang如何对cron进行二次封装实现指定时间执行定时任务问题,具有很好的参考价值,希望对大家有所帮助,如有错误... 目录背景cron库下载代码示例【1】结构体定义【2】定时任务开启【3】使用示例【4】控制台输出总结背景

Golang如何用gorm实现分页的功能

《Golang如何用gorm实现分页的功能》:本文主要介绍Golang如何用gorm实现分页的功能方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录背景go库下载初始化数据【1】建表【2】插入数据【3】查看数据4、代码示例【1】gorm结构体定义【2】分页结构体

在Golang中实现定时任务的几种高效方法

《在Golang中实现定时任务的几种高效方法》本文将详细介绍在Golang中实现定时任务的几种高效方法,包括time包中的Ticker和Timer、第三方库cron的使用,以及基于channel和go... 目录背景介绍目的和范围预期读者文档结构概述术语表核心概念与联系故事引入核心概念解释核心概念之间的关系