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

相关文章

使用协程实现高并发的I/O处理

文章目录 1. 协程简介1.1 什么是协程?1.2 协程的特点1.3 Python 中的协程 2. 协程的基本概念2.1 事件循环2.2 协程函数2.3 Future 对象 3. 使用协程实现高并发的 I/O 处理3.1 网络请求3.2 文件读写 4. 实际应用场景4.1 网络爬虫4.2 文件处理 5. 性能分析5.1 上下文切换开销5.2 I/O 等待时间 6. 最佳实践6.1 使用 as

Go Channel的实现

channel作为goroutine间通信和同步的重要途径,是Go runtime层实现CSP并发模型重要的成员。在不理解底层实现时,经常在使用中对channe相关语法的表现感到疑惑,尤其是select case的行为。因此在了解channel的应用前先看一眼channel的实现。 Channel内存布局 channel是go的内置类型,它可以被存储到变量中,可以作为函数的参数或返回值,它在r

Golang进程权限调度包runtime

关于 runtime 包几个方法: Gosched:让当前线程让出 cpu 以让其它线程运行,它不会挂起当前线程,因此当前线程未来会继续执行GOMAXPROCS:设置最大的可同时使用的 CPU 核数Goexit:退出当前 goroutine(但是defer语句会照常执行)NumGoroutine:返回正在执行和排队的任务总数GOOS:目标操作系统NumCPU:返回当前系统的 CPU 核数量 p

Golang 网络爬虫框架gocolly/colly(五)

gcocolly+goquery可以非常好地抓取HTML页面中的数据,但碰到页面是由Javascript动态生成时,用goquery就显得捉襟见肘了。解决方法有很多种: 一,最笨拙但有效的方法是字符串处理,go语言string底层对应字节数组,复制任何长度的字符串的开销都很低廉,搜索性能比较高; 二,利用正则表达式,要提取的数据往往有明显的特征,所以正则表达式写起来比较简单,不必非常严谨; 三,使

Golang网络爬虫框架gocolly/colly(四)

爬虫靠演技,表演得越像浏览器,抓取数据越容易,这是我多年爬虫经验的感悟。回顾下个人的爬虫经历,共分三个阶段:第一阶段,09年左右开始接触爬虫,那时由于项目需要,要访问各大国际社交网站,Facebook,myspace,filcker,youtube等等,国际上叫得上名字的社交网站都爬过,大部分网站提供restful api,有些功能没有api,就只能用http抓包工具分析协议,自己爬;国内的优酷、

Golang网络爬虫框架gocolly/colly(三)

熟悉了《Golang 网络爬虫框架gocolly/colly 一》和《Golang 网络爬虫框架gocolly/colly 二》之后就可以在网络上爬取大部分数据了。本文接下来将爬取中证指数有限公司提供的行业市盈率。(http://www.csindex.com.cn/zh-CN/downloads/industry-price-earnings-ratio) 定义数据结构体: type Zhj

Golang支持平滑升级的HTTP服务

前段时间用Golang在做一个HTTP的接口,因编译型语言的特性,修改了代码需要重新编译可执行文件,关闭正在运行的老程序,并启动新程序。对于访问量较大的面向用户的产品,关闭、重启的过程中势必会出现无法访问的情况,从而影响用户体验。 使用Golang的系统包开发HTTP服务,是无法支持平滑升级(优雅重启)的,本文将探讨如何解决该问题。 一、平滑升级(优雅重启)的一般思路 一般情况下,要实现平滑

Golang服务平滑重启

与重载配置相同的是我们也需要通过信号来通知server重启,但关键在于平滑重启,如果只是简单的重启,只需要kill掉,然后再拉起即可。平滑重启意味着server升级的时候可以不用停止业务。 我们先来看下Github上有没有相应的库解决这个问题,然后找到了如下三个库: facebookgo/grace - Graceful restart & zero downtime deploy for G

Golang test编译使用

创建文件my_test.go package testsimport "testing"func TestMy(t *testing.T) {t.Log("TestMy")} 通常用法: $ go test -v -run TestMy my_test.go=== RUN TestMyTestMy: my_test.go:6: TestMy--- PASS: TestMy (0.

Golang GUI入门——andlabs ui

官方不提供gui标准库,只好寻求第三方库。 https://github.com/google/gxui 这个gui库是谷歌内部人员提供的,并不是谷歌官方出品,现在停止维护,只好作罢。 第三方gui库 找了好多,也比较了好多,最终决定使用的是还是 https://github.com/andlabs/ui 相信golang gui还会发展的更好,期待更优秀的gui库 由于andlabs