本文介绍在 Go 中如何通过通道（channel）协调多个 goroutine，特别是当某个 goroutine 因错误或条件满足而退出时，安全、及时地终止仍在阻塞等待标准输入（如 fmt.Scan）的其他 goroutine。
本文介绍在 go 中如何通过通道（channel）协调多个 goroutine，特别是当某个 goroutine 因错误或条件满足而退出时，安全、及时地终止仍在阻塞等待标准输入（如 `fmt.scan`）的其他 goroutine。
在 Go 并发编程中，一个常见陷阱是：goroutine 阻塞在同步 I/O 操作（如 fmt.Scan, os.Stdin.Read）上时，无法被外部信号直接中断。原始代码中使用全局布尔变量 stop 控制循环，但 fmt.Scanf 是同步阻塞调用——即使 stop 已变为 true，sender() 仍卡在用户输入环节，导致 goroutine 无法及时退出，形成资源泄漏和逻辑僵死。
根本解法不是轮询或强制 kill（Go 不支持强制终止 goroutine），而是将 I/O 等待与控制流解耦，借助 channel 实现协作式退出。核心思想是：
- 将输入采集与业务处理分离；
- 使用无缓冲 channel 传递数据，天然具备同步与背压能力；
- 用专用 stop channel 作为退出信号，由任意 goroutine 发送，主 goroutine 或监听方接收后主动结束。
以下是一个改进后的完整示例，实现了「接收 5 条用户输入后，自动关闭读写 goroutine」：
package main
import "fmt"
func main() {
// 用于传输用户输入的字符串
pipe := make(chan string)
// 用于通知主 goroutine 退出的信号通道
stop := make(chan struct{})
// 启动输入采集 goroutine：持续读取 stdin 并发送到 pipe
go func() {
for {
var input string
if _, err := fmt.Scan(&input); err != nil {
// 输入流结束（如 Ctrl+D）或发生错误时退出采集
close(pipe)
return
}
select {
case pipe <- input:
// 正常发送
case <-stop:
// 收到退出信号，立即返回（避免向已关闭/无人接收的 channel 写入）
return
}
}
}()
// 启动处理 goroutine：从 pipe 接收最多 5 条消息，完成后发送 stop 信号
go func() {
for i := 0; i < 5; i++ {
select {
case msg, ok := <-pipe:
if !ok {
fmt.Println("Input channel closed early")
return
}
fmt.Printf("Received: %s\n", msg)
case <-stop:
fmt.Println("Stop signal received, exiting early")
return
}
}
// 完成预期数量，触发全局退出
close(stop)
}()
// 主 goroutine 阻塞等待 stop 信号，确保所有子 goroutine 安全退出
<-stop
fmt.Println("All goroutines exited gracefully.")
}✅ 关键改进点说明：
- select + stop channel：在每个可能阻塞的操作（
- close(stop) 替代 stop ：避免多次发送，且
- 错误处理：fmt.Scan 返回 err 时主动关闭 pipe，防止下游 panic；
- select 中的 case ：确保无论在读取还是写入阶段，都能即时响应退出指令。
⚠️ 注意事项：
- ❌ 不要对已关闭的 channel 执行发送操作（会导致 panic），务必配合 select 和 ok 判断；
- ❌ 避免使用全局变量（如原例中的 var stop bool）做跨 goroutine 协调——它无法解决阻塞 I/O 的唤醒问题，且存在竞态风险；
- ✅ 若需支持更复杂的生命周期管理（如超时、取消嵌套），推荐使用 context.Context（context.WithCancel），它是 stop channel 的标准化封装；
- ✅ 对于生产环境中的网络 I/O，应优先选用支持 context.Context 的 API（如 http.Client.Do(req.WithContext(ctx))），而非自行封装 channel。
总结：Go 的并发模型强调“通过通信共享内存”，而非“通过共享内存通信”。优雅关闭阻塞 goroutine 的本质，是将其从不可控的系统调用中解耦，转为可控的 channel 通信事件。只要设计好信号通道与 select 调度逻辑，就能实现完全可预测、无资源泄漏的并发退出流程。
