答复

在 Go 中，通道是实现协程之间数据传递的同步工具。可以区分：

• 无缓冲通道 — 在数据被另一个协程接收之前，发送者会被阻塞。
• 缓冲通道 — 具有固定大小的内部缓冲区。只有当缓冲区已满时，发送者才会被阻塞。

无缓冲通道适用于对同步要求严格的情况，需要保证发送者和接收者在代码的同一位置相遇。缓冲通道适合于“有余量”的数据传递 — 用于组织队列、工作者、异步任务。

示例：

func main() {
    ch := make(chan int) // 无缓冲
    go func() {
        ch <- 42 // 阻塞，直到有接收者
    }()
    fmt.Println(<-ch)

    bufch := make(chan int, 2) // 容量为 2 的缓冲通道
    bufch <- 1 // 不阻塞
    bufch <- 2 // 不阻塞
    // 如果没有读取，下一次发送将被阻塞
}

有陷阱的问题

缓冲通道可以在没有额外同步的情况下替代多个生产者和消费者之间的队列吗？

通常答案是“可以”。实际上，这仅在不重要保证顺序且消息不会丢失的情况下成立。当有多个读者/写者时，可能会发生竞态条件和数据丢失，因此仍然需要同步控制（工作池、互斥锁、关闭通道的上下文）。

由于不了解主题细节而导致的真实错误示例

---

故事

在日志处理过程中，程序员使用长度为 1000 的缓冲通道在解析器和聚合器之间传递事件。在停止服务时忘记关闭通道，部分事件“丢失” — 工作者在处理完所有缓冲之前就结束了。通过显式关闭通道和阻塞直到完全卸下进行了修复。

---

故事

在分布式服务中尝试用缓冲通道替换互斥队列时，没有考虑到“挂起”发送者的情况：在缓冲区满时，发送阻塞最终减慢了整个系统，导致超时，界面开始“卡顿”。经过分析后，将部分同步重新引入通过条件变量。

---

故事

在遥测模块中使用无缓冲通道进行错误日志的模块与消费者之间的记录。由于处理延迟，写入者被阻塞，并且在一分钟内在协程中积累了数十万条数据 — 发生了“外部 goroutine”。通过将无缓冲通道替换为缓冲通道和异步清理队列的工作者进行了修复。