Go缓冲channel和非缓冲channel的区别说明
知识点掌握了,还需要不断练习才能熟练运用。下面golang学习网给大家带来一个Golang开发实战,手把手教大家学习《Go缓冲channel和非缓冲channel的区别说明》,在实现功能的过程中也带大家重新温习相关知识点,温故而知新,回头看看说不定又有不一样的感悟!
在看本篇文章前我们需要了解阻塞的概念
在执行过程中暂停,以等待某个条件的触发 ,我们就称之为阻塞
在Go中我们make一个channel有两种方式,分别是有缓冲的和没缓冲的
缓冲channel 即 buffer channel 创建方式为 make(chan TYPE,SIZE)
如 make(chan int,3) 就是创建一个int类型,缓冲大小为3的 channel
非缓冲channel 即 unbuffer channel 创建方式为 make(chan TYPE)
如 make(chan int) 就是创建一个int类型的非缓冲channel
非缓冲channel 和 缓冲channel 的区别
非缓冲 channel,channel 发送和接收动作是同时发生的
例如 ch := make(chan int) ,如果没 goroutine 读取接收者
缓冲 channel 类似一个队列,只有队列满了才可能发送阻塞
代码演示
非缓冲 channel
package main
import (
"fmt"
"time"
)
func loop(ch chan int) {
for {
select {
case i :=
这里会报错 fatal error: all goroutines are asleep - deadlock! 就是因为 ch
但如果我们把 ch
缓冲 channel
的阻塞只会发生在 channel 的缓冲使用完的情况下
package main
import (
"fmt"
"time"
)
func loop(ch chan int) {
for {
select {
case i :=
这里也会报 fatal error: all goroutines are asleep - deadlock! ,这是因为 channel 的大小为 3 ,而我们要往里面塞 4 个数据,所以就会阻塞住
解决的办法有两个
把 channel 开大一点,这是最简单的方法,也是最暴力的
把 channel 的信息发送者 ch
补充:3种优雅的Go channel用法
写Go的人应该都听过Rob Pike的这句话
Do not communicate by sharing memory; instead, share memory by communicating.
相信很多朋友和我一样,在实际应用中总感觉不到好处,为了用channel而用。但以我的切身体会来说,这是写代码时碰到的场景不复杂、对channel不熟悉导致的,所以希望这篇文章能给大家带来点新思路,对Golang优雅的channel有更深的认识 :)
Fan In/Out
数据的输出有时候需要做扇出/入(Fan In/Out),但是在函数中调用常常得修改接口,而且上下游对于数据的依赖程度非常高,所以一般使用通过channel进行Fan In/Out,这样就可以轻易实现类似于shell里的管道。
func fanIn(input1, input2
同步Goroutine
两个goroutine之间同步状态,例如A goroutine需要让B goroutine退出,一般做法如下:
func main() {
g = make(chan int)
quit = make(chan bool)
go B()
for i := 0; i
可是了main函数没办法等待B合适地退出,所以B quit 没办法打印,程序直接退出了。
然而,chan是Go里的第一对象,所以可以把chan传入chan中,所以上面的代码可以把quit 定义为chan chan bool,以此控制两个goroutine的同步
func main() {
g = make(chan int)
quit = make(chan chan bool)
go B()
for i := 0; i
分布式递归调用
在现实生活中,如果你要找美国总统聊天,你会怎么做?
第一步打电话给在美国的朋友,然后他们也会发动自己的关系网,再找可能认识美国总统的人,以此类推,直到找到为止。
这在Kadmelia分布式系统中也是一样的,如果需要获取目标ID信息,那么就不停地查询,被查询节点就算没有相关信息,也会返回它觉得最近节点,直到找到ID或者等待超时。
好了,这个要用Go来实现怎么做呢?
func recursiveCall(ctx context.Context, id []byte, initialNodes []*node){
seen := map[string]*node{} //已见过的节点记录
request := make(chan *node, 3) //设置请求节点channel
// 输入初始节点
go func() {
for _, n := range initialNodes {
request
这时的buffered channel类似于一个局部queue,对需要的节点进行处理,但这段代码的精妙之处在于,这里的block操作是select的,随时可以取消,而不是要等待或者对queue的长度有认识。
以上为个人经验,希望能给大家一个参考,也希望大家多多支持golang学习网。如有错误或未考虑完全的地方,望不吝赐教。
文中关于golang的知识介绍,希望对你的学习有所帮助!若是受益匪浅,那就动动鼠标收藏这篇《Go缓冲channel和非缓冲channel的区别说明》文章吧,也可关注golang学习网公众号了解相关技术文章。
go原生库的中bytes.Buffer用法
- 上一篇
- go原生库的中bytes.Buffer用法
- 下一篇
- Go语言使用select{}阻塞main函数介绍
-
- Golang · Go教程 | 4小时前 | 错误处理 · regexp · Go教程 · 配置热加载 · Go regexp.Compile 正则表达式配置 配置错误处理
- Go regexp 编译正则失败时怎么把错误交给配置层
- 222浏览 收藏
-
- Golang · Go教程 | 4小时前 |
- Go regexp.FindAllStringSubmatchIndex 怎么映射捕获组位置
- 134浏览 收藏
-
- Golang · Go教程 | 5小时前 | go · 有理数 · 高精度计算 · 浮点误差 · math/big.Rat FloatString big.NewRat SetFrac64 SetString RatString
- Go math/big.Rat 怎么精确计算分数而不是浮点近似
- 312浏览 收藏
-
- Golang · Go教程 | 5小时前 |
- Go strconv.NumError 怎么拿到具体转换字段
- 301浏览 收藏
-
- Golang · Go教程 | 5小时前 |
- Go strconv.ParseFloat 遇到 NaN 和 Inf 怎么区分
- 501浏览 收藏
-
- Golang · Go教程 | 7小时前 | Timer · go · 性能优化 · time.After ·
- Go time.After 在高频循环中为什么会造成延迟对象堆积
- 313浏览 收藏
-
- Golang · Go教程 | 7小时前 |
- Go strconv.AppendQuote 怎么低分配地拼接带引号字符串
- 184浏览 收藏
-
- Golang · Go教程 | 8小时前 | 并发 · 定时器 · go · time.Timer time.NewTimer time.Stop time.Reset
- Go time.Timer 通道读不到事件时怎么判断定时器当前状态
- 173浏览 收藏
-
- Golang · Go教程 | 8小时前 | 定时任务 · 并发控制 · Go教程 · 资源释放 · Go Goroutine context 后台任务 time.Ticker Ticker.Stop
- Go time.Ticker 不再使用时怎么停止避免后台任务残留
- 297浏览 收藏
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
- 543次学习
-
- GO语言核心编程课程
- 本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
- 516次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
- 500次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
- 485次学习
-
- H2O EvalGPT
- H2O EvalGPT是H2O.ai推出的开源LLM评估平台,提供详细的大模型性能排行榜、行业特定基准测试及A/B测试功能,助您快速选择最适合项目的高性能大语言模型。
- 53次使用
-
- SuperCLUE
- SuperCLUE是权威的中文大语言模型综合评测基准,涵盖语言理解、知识应用、AI Agent智能体及安全性等12项核心能力。通过多轮对话与客观测试,定期发布榜单与技术报告,为模型研发、优化及行业选型提供科学依据。
- 204次使用
-
- C-Eval
- 深入了解C-Eval中文评估套件,涵盖52个学科与4级难度。本文详解其功能特点、Zero-shot/Few-shot使用方法及代码示例,助您全面评测LLM中文理解与泛化能力。
- 139次使用
-
- AI Prompt Library
- 探索AI Prompt Library免费资源库,涵盖营销、写作及多场景AI提示词。兼容ChatGPT、Claude等工具,一键复制优化输出,提升工作效率。
- 71次使用
-
- Generrated
- Generrated汇集9300+张DALL·E生成图像及对应提示词,支持查看完整图集、对比DALL·E 2与3版本差异,是AI绘图新手学习Prompt设计与获取创作灵感的实用工具。
- 52次使用
-
- 深入理解Golangchannel的应用
- 2023-01-27 200浏览
-
- GoLangchannel使用介绍
- 2022-12-22 440浏览
-
- Go语言面试题之select和channel的用法
- 2022-12-30 477浏览
-
- Go底层channel实现原理及示例详解
- 2022-12-24 399浏览
-
- Golang channel为什么不会阻塞的原因详解
- 2023-01-27 455浏览
