如何使用Golang实现协程间通信_Golang channel与select使用实践

发布时间 - 2026-01-25 00:00:00    点击率:
channel是goroutine间通信的唯一推荐方式,无缓冲channel需收发同步,带缓冲channel可暂存数据;向已关闭channel发送会panic,接收则返回零值;select需default或阻塞操作,否则可能永久阻塞。

channel 是协程通信的唯一安全通道

Go 中没有共享内存式通信,channelgoroutine 之间传递数据的**唯一推荐方式**。直接读写全局变量或结构体字段会导致竞态(data race),即使加锁也违背 Go “通过通信共享内存” 的设计哲学。

使用 channel 时必须注意:它默认是阻塞的,发送和接收会互相等待;容量为 0(即无缓冲)时,收发必须同时就绪才能完成。

  • make(chan int) 创建无缓冲 channel,适合同步信号(如“任务完成通知”)
  • make(chan string, 10) 创建带缓冲 channel,可暂存 10 个值,避免发送方立即阻塞
  • 向已关闭的 channel 发送会 panic;从已关闭的 channel 接收会立即返回零值 + false

select 多路复用必须配 default 或阻塞操作

select 不是轮询,而是 Go 运行时提供的**非阻塞多路等待机制**。如果所有 case 都不可达(例如所有 channel 都空且无 default),select 会永久阻塞——这是常见卡死原因。

典型误用:select 只有 recv 操作但没 default,而 sender 还没启动或延迟发送。

立即学习“go语言免费学习笔记(深入)”;

ch := make(chan int)
// ❌ 卡死:ch 为空,又没 default
select {
case x := <-ch:
    fmt.Println(x)
}
// ✅ 加 default 实现非阻塞尝试
select {
case x := <-ch:
    fmt.Println("received:", x)
default:
    fmt.Println("no data yet")
}

超时控制必须用 time.After 或 context.WithTimeout

不能靠循环 + select + time.Sleep 实现超时,这会浪费 goroutine 和时间精度差。Go 标准做法是把 time.After(d) 当作一个只发一次的 channel 来参与 select

  • time.After(3 * time.Second) 返回 ,3 秒后自动发送当前时间
  • 更健壮的做法是用 context.WithTimeout,尤其在涉及子 goroutine 传播取消信号时
  • 注意:time.After 不可重用,每次超时需新建
ch := make(chan string, 1)
go func() {
    time.Sleep(5 * time.Second)
    ch <- "done"
}()
select {
case msg := <-ch:
    fmt.Println(msg)
c

ase <-time.After(2 * time.Second): fmt.Println("timeout!") }

关闭 channel 前确保所有 sender 已退出

close() 只应由 sender 调用,且**只能关闭一次**。过早关闭会导致 receiver 收到零值并误判为有效数据;重复关闭 panic。

常见模式是用 sync.WaitGroup 等待所有 sender 完成后再关闭:

ch := make(chan int, 10)
var wg sync.WaitGroup
wg.Add(2)
go func() {
    defer wg.Done()
    for i := 0; i < 5; i++ {
        ch <- i
    }
}()
go func() {
    defer wg.Done()
    for i := 5; i < 10; i++ {
        ch <- i
    }
}()
go func() {
    wg.Wait()
    close(ch) // 所有 sender 结束后才关
}()
for v := range ch { // range 自动检测 closed
    fmt.Println(v)
}

真正难的是协调多个 sender 的生命周期,尤其是存在错误提前退出、或需要中途取消的情况——这时候得结合 context 和显式状态检查,不能只依赖 close


# go  # golang  # String  # select  # 全局变量  # 结构体  # int  # 循环  # channel  # default  # 多路  # 的是  # 这是  # 还没  # 都不  # 尤其是  # 多个  # 可达  # 后才  # 又没 


相关栏目: 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571


相关推荐: laravel怎么通过契约(Contracts)编程_laravel契约(Contracts)编程方法  Laravel怎么使用Intervention Image库处理图片上传和缩放  javascript中闭包概念与用法深入理解  linux写shell需要注意的问题(必看)  Win11摄像头无法使用怎么办_Win11相机隐私权限开启教程【详解】  node.js报错:Cannot find module &#39;ejs&#39;的解决办法  韩国服务器如何优化跨境访问实现高效连接?  html5源代码发行怎么设置权限_访问权限控制方法与实践【指南】  Laravel怎么创建控制器Controller_Laravel路由绑定与控制器逻辑编写【指南】  如何在阿里云服务器自主搭建网站?  如何彻底卸载建站之星软件?  Laravel Asset编译怎么配置_Laravel Vite前端构建工具使用  Laravel如何与Docker(Sail)协同开发?(环境搭建教程)  Win11怎么开启自动HDR画质_Windows11显示设置HDR选项  Laravel怎么集成Vue.js_Laravel Mix配置Vue开发环境  使用豆包 AI 辅助进行简单网页 HTML 结构设计  html5如何实现懒加载图片_ intersectionobserver api用法【教程】  Win10如何卸载预装Edge扩展_Win10卸载Edge扩展教程【方法】  Python面向对象测试方法_mock解析【教程】  夸克浏览器网页跳转延迟怎么办 夸克浏览器跳转优化  Laravel如何获取当前登录用户信息_Laravel Auth门面使用与Session用户读取【技巧】  Win11怎么设置虚拟桌面 Win11新建多桌面切换操作【技巧】  公司网站制作价格怎么算,公司办个官网需要多少钱?  Edge浏览器怎么启用睡眠标签页_节省电脑内存占用优化技巧  PHP 500报错的快速解决方法  Laravel如何将应用部署到生产服务器_Laravel生产环境部署流程  ChatGPT常用指令模板大全 新手快速上手的万能Prompt合集  DeepSeek是免费使用的吗 DeepSeek收费模式与Pro版本功能详解  Laravel如何实现API版本控制_Laravel版本化API设计方案  轻松掌握MySQL函数中的last_insert_id()  javascript中的try catch异常捕获机制用法分析  如何在Tomcat中配置并部署网站项目?  Android中Textview和图片同行显示(文字超出用省略号,图片自动靠右边)  深圳网站制作的公司有哪些,dido官方网站?  教你用AI将一段旋律扩展成一首完整的曲子  香港服务器网站推广:SEO优化与外贸独立站搭建策略  如何在阿里云通过域名搭建网站?  Laravel集合Collection怎么用_Laravel集合常用函数详解  高性能网站服务器配置指南:安全稳定与高效建站核心方案  高端建站如何打造兼具美学与转化的品牌官网?  智能起名网站制作软件有哪些,制作logo的软件?  如何解决hover在ie6中的兼容性问题  微信推文制作网站有哪些,怎么做微信推文,急?  如何用景安虚拟主机手机版绑定域名建站?  Python文件异常处理策略_健壮性说明【指导】  如何在IIS7中新建站点?详细步骤解析  如何用腾讯建站主机快速创建免费网站?  JavaScript如何实现继承_有哪些常用方法  如何在阿里云ECS服务器部署织梦CMS网站?  如何在IIS中新建站点并配置端口与物理路径?