Go 中单通道并发的阻塞行为与程序退出机制详解-Golang-PHP中文网

Go 中单通道并发的阻塞行为与程序退出机制详解

Go 程序在 main 函数返回时立即终止，不等待其他 goroutine 完成；即使通道收发操作天然阻塞，若缺乏同步机制，接收 goroutine 可能来不及处理全部数据便随主程序退出而被强制终止。

go 程序在 `main` 函数返回时立即终止，不等待其他 goroutine 完成；即使通道收发操作天然阻塞，若缺乏同步机制，接收 goroutine 可能来不及处理全部数据便随主程序退出而被强制终止。

在您提供的代码中，问题本质并非通道“不阻塞”，而是程序生命周期管理缺失。让我们逐步分析：

func main() {
    c := make(chan int)
    go func() {
        for i := 0; i

go func() 启动一个接收 goroutine，它首次从 c 接收时会阻塞（因 channel 为空），直到 sendNumbers(c) 开始发送。
sendNumbers(c) 在 main 中同步执行：先发 0 → 接收 goroutine 解阻塞、打印 0、继续循环 → 再次 阻塞等待；
此时 sendNumbers(c) 发送 1 → 接收 goroutine 解阻塞、打印 1、循环结束、goroutine 正常退出。

看似逻辑完整——但关键在于：main 函数在 sendNumbers(c) 返回后立即结束，整个程序随之退出。而 Go 运行时不会保证已启动的 goroutine 执行完成。即使接收 goroutine 正在打印 1 或刚完成，只要 main 返回，进程即终止，可能导致输出截断（如仅看到 0）或完全丢失 1。

time.Sleep(1 * time.Second) “生效”，只是巧合地让 main 多存活了一秒，给了接收 goroutine 足够时间完成两次接收和打印——但这属于竞态依赖时间延迟的脆弱方案，绝不可用于生产环境。

✅ 正确解法：使用同步机制确保 main 等待接收完成。推荐两种 Go 风格方案：

方案一：使用 sync.WaitGroup（显式计数）

package main

import (
    "fmt"
    "sync"
)

func sendNumbers(c chan int) {
    for i := 0; i <p><strong>方案二：纯通道同步（更符合 Go 并发哲学）</strong></p><pre class="brush:php;toolbar:false;">package main

import "fmt"

func sendNumbers(c chan int, done chan struct{}) {
    for i := 0; i <p>⚠️ 注意事项：</p>