Golang 协程配合管道的实现示例
更新时间：2024年01月11日 11:09:35 作者：富士康质检员张全蛋
本文主要介绍了Golang协程配合管道的实现示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
请完成goroutine和channel协同工作的案例，具体要求：
（1）开启一个writeData协程，向管道mtChan中写入50个整数.
（2）开启一个readData协程，从管道intChan中读取writeData写入的数据。
（3）注意：writeData和readDate操作的是同一个管道
（4）主线程需要等待writeData和readDate协程都完成工作才能退出（如果主线程不做处理，那么其他线程还没干完活就直接跑路了）
管道是引用类型，那么写入读取的都是同一个管道，也就是在不同函数不同栈里面读取的都是同一个管道。两个协程同时的向管道里面写入读取数据，而不是一个写完另外一个协程再去读取。
package main
import (
"fmt"
)
func writeData(initChan chan int) {
for i := 0; i <= 50; i++ {
//放入数据
initChan <- i
fmt.Println("write data:", i)
}
close(initChan)
}
func readData(initChan chan int, exitChan chan bool) {
//即使管道close之后并不影响读取，当在管道当中取不到数据才会退出
for {
//在从一个管道里面读取会返回两个值，ok是有没有正确读取到
v, ok := <-initChan
if !ok {
break
}
fmt.Println("read data:", v)
}
//readData任务完成之后
exitChan <- true
close(exitChan)
}
func main() {
//创建两个管道
initChan := make(chan int, 50)
exitChan := make(chan bool, 1)
go writeData(initChan)
go readData(initChan, exitChan)
for {
_, ok := <-exitChan
fmt.Println("ok=", ok)
if ok {
break
}
}
}如果给的容量就是50，那么循环50次就刚好放进去了。如果管道和放进去的数据量不匹配，管道的容量小于放进去的数据，又不取出来，那么它就会阻塞，就会死锁。
这个管道可以容纳的数据量很小，要写的数据量很大，只要一边在写，另外一边在读是无所谓的。
如果写的快，读取的慢。那么在写的时候就会阻塞，编译器会发现虽然阻塞了，但是有另外一个协程在往里面读取数据，这样就不会发生死锁。
func producer(ch chan int) {
i := 0
for {
ch <- i
i++
}
}
func main() {
ch := make(chan int, 2)
go producer(ch)
for {
fmt.Println(<-ch)
time.Sleep(time.Second * 2)
}
}
0
1
2
3
4
5
6
7
进程 已完成，退出代码为 -1073741510 (0xC000013A: interrupted by Ctrl+C)
死锁编译器底层会分析，如果发现一个地方在不停的写，但是没有任何一个协程去读取这样就直接死锁，如果有一个协程在慢慢的读取这样不会死锁。和写入读取速度没有关系，但是必须有写入的协程和读取的协程。简而言之就是管道需要不停的流动。
到此这篇关于Golang 协程配合管道的文章就介绍到这了,更多相关Golang 协程配合管道内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
本文是对泛型的基本思想及其在 Go 中的实现的一个比较容易理解的介绍，同时也是对围绕泛型的各种性能讨论的简单总结，感兴趣的可以学习一下2022-05-05
限流是项目中经常需要使用到的一种工具，一般用于限制用户的请求的频率，也可以避免瞬间流量过大导致系统崩溃，或者稳定消息处理速率。这篇文章主要是使用Go+Redis实现常见的限流算法，需要的可以参考一下2023-04-04
随着科技的进步，人人都想要快速的应用，这就需要优化您的应用程序性能。本文为大家整理了一些Golang应用程序性能优化的技巧，希望对大家有所帮助2023-04-04
fasthttp 是 Go 的快速 HTTP 实现，当前在 1M 并发的生产环境使用非常成功，可以从单个服务器进行 100K qps 的持续连接，总而言之，fasthttp 比 net/http 快 10 倍，下面通过本文给大家介绍golang fasthttp http请求的相关知识，一起看看吧2021-09-09
DeepSeek是一个强大的AI模型服务平台,本文将详细介绍如何使用Go语言调用DeepSeek API实现流式输出和对话功能,感兴趣的小伙伴可以了解一下2025-02-02
这篇文章主要介绍了Go语言Elasticsearch数据清理工具思路详解,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2021-10-10
这篇文章主要为大家介绍了Go Comparable Type原理深入解析，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2023-01-01
这篇文章主要介绍了Go语言在Linux环境下输出彩色字符的方法,本文给大家介绍的非常详细，具有一定的参考借鉴价值，需要的朋友可以参考下2019-04-04
Golang时间处理库go-carbon v2.2.13发布细则
这篇文章主要为大家介绍了Golang 时间处理库go-carbon v2.2.13发布细则,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪2023-11-11
在日常开发中,我们通常需要针对现有的功能进行单元测试,以验证开发的正确性,本文主要介绍了Go语言单元测试的实现及用例,具有一定的参考价值,感兴趣的可以了解一下2024-01-01
最新评论