17370845950

Go中协程间共享数据应优先使用channel而非全局变量或加锁；buffered channel天然实现线程安全FIFO队列，支持阻塞读写、关闭通知、非阻塞操作及封装扩展。

在 Go 中，协程（goroutine）间共享数据时，不推荐直接使用全局变量或共享内存加锁，而应优先通过 channel 进行通信。队列场景下，channel 本身就是一个天然的、线程安全的先进先出（FIFO）缓冲区，无需额外同步机制。

用 buffered channel 模拟带容量的队列

声明一个带缓冲的 channel 即可作为线程安全的队列：

• queue := make(chan int, 10) 创建容量为 10 的整数队列，写入和读取自动阻塞/唤醒，保证并发安全
• 发送操作 queue 在满时阻塞，接收操作 在空时阻塞，天然实现生产者-消费者节奏控制
• 无需 sync.Mutex 或 sync.WaitGroup 即可安全地被多个 goroutine 同时读写

关闭 channel 表示队列“已耗尽”

当生产者完成投递，应显式关闭 channel，通知消费者不再有新数据：

• 生产者调用 close(queue)（只能由发送方关闭）
• 消费者用 for v := range queue 自动退出循环；或用 v, ok := 判断是否已关闭（ok == false 表示已关闭且无剩余数据）
• 注意：向已关闭的 channel 发送会 panic，务必确保只有生产者关闭，且只关一次

用 select + default 避免阻塞，实现非阻塞队列操作

若需“尝试入队/出队而不等待”，可用 select 配合 default：

• 非阻塞入队：select { case queue
• 非阻塞出队：select { case v :=
• 适合做限流、快速失败、或与超时逻辑结合（如加 time.After）

复杂队列行为？封装成结构体 + channel 组合

当需要长度查询、清空、或动态调整容量等能力，可封装 channel 和辅助字段：

• 定义结构体包含 ch chan T 和 mu sync.RWMutex（仅用于保护非 channel 字段，如 len 计数器）
• 但注意：真实长度仍应以 len(ch) 为准（仅在未被其他 goroutine 并发操作瞬间有效），一般业务无需精确长度，依赖 channel 自身阻塞语义更可靠
• 避免为“看起来像传统队列”而过度封装——Go 的哲学是“用 channel 通信，不要用共享内存通信”