使用channel实现并发安全消息队列，通过带缓冲channel如queue := make(chan String, 10)支持生产者-消费者模型，无需额外锁机制。
在go语言中实现并发安全的消息队列，核心思路是利用Go内置的并发机制来避免多个goroutine同时操作共享数据时出现竞争。最常用且推荐的方式是使用channel，因为它天生就是并发安全的，无需额外加锁。
使用Channel实现基础并发队列
Go的channel本身就是线程安全的数据结构，非常适合用来构建消息队列。通过缓冲channel，可以实现生产者-消费者模型。
- 创建一个带缓冲的
channel作为消息存储，例如queue := make(chan string, 10) - 生产者协程通过
queue 发送消息 - 消费者协程通过
message := 接收消息 - 当所有生产者完成时，关闭
channel，消费者会自动退出
这种方式简单高效，适用于大多数场景，如日志收集、任务分发等。
结合Mutex实现自定义队列结构
如果需要更复杂的队列行为（比如优先级、延迟处理），可以基于切片或链表手动实现，并用sync.Mutex或sync.RWMutex保护共享状态。
立即学习“go语言免费学习笔记（深入）”；
- 定义一个结构体包含数据存储和互斥锁，例如包含
[]string和sync.Mutex - 每次入队（Enqueue）和出队（Dequeue）前先调用
Lock()，操作完成后调用Unlock() - 使用
defer mu.Unlock()确保锁一定会被释放
这种方法灵活性高，但要注意避免死锁和性能瓶颈，锁的粒度不宜过大。
处理通道阻塞与超时
直接写入或读取channel可能因缓冲区满或空而阻塞。可以通过select语句配合time.After()实现超时控制。
- 发送消息时使用
select尝试写入，若超过指定时间仍无法写入则返回错误 - 接收消息时同样可用
select设置超时，防止无限等待 - 这在高负载或网络不稳定环境下能提升系统健壮性
合理设置缓冲大小和超时时间，可以在吞吐量和响应速度之间取得平衡。