Go语言中channel是协程通信与同步的核心抽象通道,用于任务分发、结果收集和并发控制;典型用法包括带缓冲channel分发任务、for range收集结果并配合WaitGroup确保安全关闭,以及用容量受限channel实现限流。

Go 语言中,channel 是协程(goroutine)间通信与同步的核心机制,不是用来共享内存的“管道”,而是承载数据传递、控制流协调和状态同步的抽象通道。用好 channel,关键不在于“传什么”,而在于“何时传、谁等谁、传完怎么继续”。
用 channel 实现任务分发与结果收集
典型场景:启动多个 goroutine 并行处理一批任务,主协程等待全部完成并汇总结果。
建议使用带缓冲的 channel 分发任务(避免发送阻塞),再用无缓冲或带缓冲 channel 收集结果,并配合 sync.WaitGroup 或 for range + 关闭 channel 来判断完成:
- 先创建
jobs := make(chan int, 10)和results := make(chan int, 10) - 启动 N 个 worker goroutine,每个循环接收 job、处理、发送 result 到 results
- 主协程关闭 jobs channel(表示任务发完了),再用
for range results自动等待所有结果送达 - 注意:必须确保所有 worker 都已退出,再关闭 results,否则可能 panic;更稳妥方式是用 WaitGroup 等待 worker 结束,再关闭 results
用 channel 控制并发数量(限流)
避免瞬间启动成百上千 goroutine 压垮系统,可用 channel 作“信号量”来限制活跃协程数。
立即学习“go语言免费学习笔记(深入)”;
篇文章是针对git版本控制和工作流的总结,如果有些朋友之前还没使用过git,对git的基本概念和命令不是很熟悉,可以从以下基本教程入手: Git是分布式版本控制系统,与SVN类似的集中化版本控制系统相比,集中化版本控制系统虽然能够令多个团队成员一起协作开发,但有时如果中央服务器宕机的话,谁也无法在宕机期间提交更新和协同开发。甚至有时,中央服务器磁盘故障,恰巧又没有做备份或备份没及时,那就可能有丢失数据的风险。感兴趣的朋友可以过来看看
做法很简单:创建一个容量为 N 的 channel,比如 sem := make(chan struct{}, 3)。每个 goroutine 启动前先向 sem 发送一个空结构体(获取许可),处理完再接收一次(释放许可):
sem —— 若已满则阻塞,自然实现排队- 处理逻辑…
—— 归还许可,让下一个协程进入- 这种模式比 time.Sleep 或轮询更轻量、更符合 Go 的 CSP 思想
用 select + timeout 防止 goroutine 永久阻塞
从 channel 接收数据时,若发送方永不发送,接收方会一直挂起。用 select 配合 time.After 可设置超时,让协作更健壮。
- 写法示例:
select { case res := - 也可用
default分支实现非阻塞尝试(类似“if channel not empty then read”) - 注意:不要在循环里反复创建 time.After,应复用 timer 或改用 time.NewTimer 后 Reset
关闭 channel 的正确时机与含义
关闭 channel 表示“不会再有新数据发送”,仅应由发送方关闭,且只能关一次。接收方通过 v, ok := 中的 ok 判断是否已关闭。
- 常见误用:多个 sender 共同向同一 channel 发送,却由其中一个关闭 —— 其他 sender 再发送会 panic
- 安全做法:用单独 goroutine 统一管理发送,或用 sync.Once + channel 关闭标记
- 接收方看到
ok == false,说明 channel 已关且缓冲区清空,可安全退出循环









