如何使用Golang channel进行协程通信_传递数据和同步操作

10次阅读

channel 是 Go 中 goroutine 间通信与同步的核心机制,通过“通信来共享内存”实现安全数据传递,支持阻塞、等待与协调;声明需指定元素类型(如 chan int),发送用 ch

如何使用 Golang channel 进行协程通信_传递数据和同步操作

Go 语言中,channel 是协程(goroutine)间通信和同步的核心机制。它既不是锁也不是共享内存,而是通过“通信来共享内存”的设计哲学,让数据在 goroutine 之间安全传递,同时天然支持等待、阻塞与协调。

用 channel 传递数据:基础写法与注意事项

声明 channel 需指定元素类型,如 chan int;发送用 ch,接收用 <code>value :=。channel 默认是双向且未缓冲的,这意味着发送和接收必须同时就绪,否则会阻塞。

  • 未缓冲 channel 的操作是同步的:发送方会一直等待,直到有接收方准备就绪
  • 缓冲 channel(如 make(chan int, 5))可暂存数据,发送不立即阻塞,但满时仍会阻塞
  • 向已关闭的 channel 发送数据会 panic,但可继续从已关闭的 channel 接收,此时返回零值并 ok 为 false

用 channel 实现 goroutine 同步:替代 waitgroup 的简洁方式

比起显式使用 sync.WaitGroup,channel 更符合 Go 的风格——用通信代替等待。常见做法是启动 goroutine 后,用 channel 通知主协程“我做完了”。

  • 定义一个 done := make(chan struct{})(struct{} 零开销,仅作信号)
  • goroutine 执行完后写入:done
  • 主 goroutine 用 等待,无需计数或 Add/Done 调用
  • 若需等待多个任务,可用 for i := 0; i,或配合 <code>select 处理超时

用 select + channel 处理多路通信与超时控制

select 是 Go 中专为 channel 设计的多路复用语句,类似 I/O 多路复用。它让 goroutine 可以同时监听多个 channel 操作,并在任一就绪时执行对应分支。

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

  • 每个 case 对应一个 channel 操作(发送 / 接收),没有默认 case 时,所有 channel 都阻塞则整个 select 阻塞
  • 加入 default 分支可实现非阻塞尝试(即“如果没数据就跳过”)
  • 常用超时模式:case
  • 注意:select 是随机选择就绪的 case,避免因顺序导致隐含依赖

关闭 channel 与 range 遍历:安全消费所有数据

当 sender 不再发送数据时,应关闭 channel,这样 receiver 可通过 range 安全遍历直至结束,或用双赋值判断是否关闭。

  • 只有 sender 应关闭 channel;receiver 关闭会 panic
  • for v := range ch {……} 会在 channel 关闭且数据读尽后自动退出
  • 手动接收时用 v, ok :=:ok 为 true 表示成功收到,false 表示 channel 已关闭且无剩余数据
  • 不要在多个 goroutine 中重复关闭同一 channel,可配合 sync.Once 或只由唯一 sender 控制

channel 不是万能的,但它把并发逻辑表达得清晰而可控。合理搭配无缓冲 / 缓冲、关闭时机、select 和 range,就能写出健壮、易读、低耦合的并发代码。

text=ZqhQzanResources