如何在 Go 中阻塞程序/Goroutine?

来源:SQLite教程作者:小何头衔:草根站长
导读:本期聚焦于小何创作的《如何在 Go 中阻塞程序/Goroutine?》,敬请观看详情。main 函数一旦返回,Go 进程就会退出,所有还在运行的 Goroutine 都会被直接终止。要避免任务被中途掐断,就需要让主 Goroutine 保持阻塞。常用的手段包括空 select{} 永久挂起、从 nil 通道接收数据、使用 sync.WaitGroup 等待一组任务完成,以及通过 channel 接收退出信号。不同的阻塞方式资源消耗和行为差异很大:select{} 和通道接收会让出 CPU 调度资源,而 for{} 这类忙等循环会占满整个核心。本文结合代码示例对比几种阻塞实现,分析它们适合的场景,并说明如何借助系统信号实现可优雅退出的阻塞。比如后台服务通常需要监听 SIGINT 或 SIGTERM,在收到信号后完成清理再退出;而一次性脚本可能只需要等待所有 worker 完成。理解这些差异后,你可以根据是否需要等待任务、是否要响应外部信号来选择合适的阻塞方式,避免写出耗尽 CPU 或无法退出的程序。

接触 Go 并发模型时,最容易踩的一个坑是:main 函数返回后,整个进程直接退出,其他 Goroutine 会被无声地终止。假设你写了一个异步写日志的 Goroutine,或者启动了几个后台 worker,只要主函数执行完毕,这些任务大概率还没跑完程序就结束了。这是因为 Go 运行时不会等待普通 Goroutine 完成,main 函数返回相当于触发进程退出。因此,理解如何在 Go 中阻塞主 Goroutine,是写出可靠并发程序的基本功。

如何在 Go 中阻塞程序/Goroutine?

主 Goroutine 退出会带来什么

先看一个最简单的例子。下面这段代码在 main 函数中启动了三个 worker Goroutine,每个 worker 会先休眠 200 毫秒再打印完成信息。

package main

import (
    "fmt"
    "time"
)

func worker(id int) {
    time.Sleep(200 * time.Millisecond)
    fmt.Println("worker", id, "done")
}

func main() {
    for i := 1; i <= 3; i++ {
        go worker(i)
    }
    // main 很快返回,可能看不到任何输出
}

实际运行这段代码,很可能看不到任何输出。原因在于 main 函数在启动完 Goroutine 后立刻返回,进程退出时所有 Goroutine 都会被终止,根本没有机会执行到打印语句。即使某些极端情况下调度器抢在 main 返回前执行了 worker,输出也不完整、不稳定。这个例子说明:如果希望后台任务可靠执行,就不能让 main 函数直接结束。

一种临时做法是在 main 末尾加上 time.Sleep,比如睡上一秒。但这种方式非常脆弱,任务执行时间稍微变长就会出问题,而且它只能等待固定时长,无法感知任务是否真正完成。正确思路是让主 Goroutine 进入阻塞状态,直到满足某个条件后再退出。接下来看看几种实现阻塞的方式。

用空 select{} 和 nil 通道实现永久阻塞

Go 语言里最直接的永久阻塞写法是空 select 语句。select 通常用于监听多个通道操作,当它没有任何 case 时,当前 Goroutine 会永远挂起,并且会让出所占用的调度资源,不会消耗 CPU。

package main

import (
    "fmt"
    "time"
)

func main() {
    go func() {
        time.Sleep(time.Second)
        fmt.Println("后台任务完成")
    }()

    select{} // 永久阻塞主 goroutine
}

执行这段代码后,程序不会退出,后台 Goroutine 在休眠一秒后会打印完成信息。空 select 的原理是它没有任何可以触发的通信操作,调度器会把这个 Goroutine 置为阻塞状态,因此它不是忙等。与之类似的是从 nil 通道接收数据。Go 中 nil 通道上的发送和接收都会永久阻塞,因为没有任何 Goroutine 能与之配对。

package main

func main() {
    var ch chan int
    <-ch // 从 nil channel 接收,永久阻塞
}

这两种写法的共同点是简单,适合主程序只需要挂在那里、后台 Goroutine 自行运行的场景。缺点是它们没有任何退出机制,一旦使用,程序只能通过外部信号强制杀死。对于一个需要优雅关闭的服务来说,这还不够。另外要特别注意,空 select 和 nil 通道接收都属于真正的阻塞,而 for{} 无限循环不是阻塞,它会让一个 CPU 核心持续空转,最终把资源耗尽。

用 sync.WaitGroup 等待任务完成

如果需要阻塞主 Goroutine 直到一批并发任务全部完成,sync.WaitGroup 是最合适的工具。它内部维护一个计数器,Add 方法增加计数,Done 方法减少计数,Wait 方法会阻塞到计数器归零。

package main

import (
    "fmt"
    "sync"
)

func worker(id int, wg *sync.WaitGroup) {
    defer wg.Done()
    fmt.Printf("worker %d started\n", id)
    // 模拟耗时操作
}

func main() {
    var wg sync.WaitGroup
    for i := 1; i <= 5; i++ {
        wg.Add(1)
        go worker(i, &wg)
    }
    wg.Wait() // 阻塞直到所有 worker 调用 Done
    fmt.Println("all workers done")
}

上面的循环在每次启动 worker 前调用 wg.Add(1),主 Goroutine 执行 wg.Wait() 时会被阻塞,直到五个 worker 都执行完 defer wg.Done()。这是一个带明确结束条件的阻塞方式,比空 select 和 time.Sleep 都可靠得多。需要注意的是,Add 调用应该放在启动 Goroutine 的循环中,而不是放在 worker 函数内部。如果所有 worker 都在 goroutine 内部才 Add,可能出现主 Goroutine 已经执行到 Wait 时计数器仍为零的情况,导致 Wait 提前返回。

WaitGroup 非常适合批量任务、并发请求、worker 池等场景。不过它只解决等待任务完成的问题,并不提供外部退出信号。如果程序是一个长时间运行的服务,主 Goroutine 可能需要等待的是操作系统信号,而不是所有任务自然结束。

用 channel 接收退出信号和系统信号

通过 channel 也可以实现只阻塞到某个条件成立。常见做法是创建一个 done channel,worker 完成后往里面发送一个值,主 Goroutine 从通道接收数据,这个接收操作会阻塞主 Goroutine。

package main

import (
    "fmt"
    "time"
)

func worker(done chan struct{}) {
    time.Sleep(300 * time.Millisecond)
    fmt.Println("worker finished")
    done <- struct{}{}
}

func main() {
    done := make(chan struct{})
    go worker(done)
    <-done // 阻塞直到 worker 发信号
    fmt.Println("main exits")
}

这种写法和 WaitGroup 有相似的效果,但 WaitGroup 更适合批量任务,而 done channel 更灵活,可以携带数据、可以在多个 Goroutine 之间传递明确的完成事件。比如你可以定义 chan error,让 worker 返回错误,主 Goroutine 接收后决定是否继续等待。

对于常驻服务,更实用的方式是阻塞等待系统信号。下面这段代码使用 signal.Notify 把 SIGINT 和 SIGTERM 转发到一个通道,主 Goroutine 从通道接收信号时会一直阻塞,直到用户按下 Ctrl+C 或进程收到终止信号。

package main

import (
    "fmt"
    "os"
    "os/signal"
    "syscall"
)

func main() {
    ch := make(chan os.Signal, 1)
    signal.Notify(ch, syscall.SIGINT, syscall.SIGTERM)

    go func() {
        // 模拟后台服务
        fmt.Println("service running...")
        select{}
    }()

    sig := <-ch // 阻塞直到收到信号
    fmt.Println("received signal:", sig)
    // 执行清理逻辑
}

收到信号后,程序可以执行清理工作,比如关闭数据库连接、刷写日志、通知其他 Goroutine 停止,然后再返回。这样既实现了阻塞,又保留了优雅退出的能力。实际项目中还可以结合 context.WithCancel,在收到信号后取消 context,把退出通知传递给所有依赖该 context 的 Goroutine。

选择建议与常见误区

总结一下,不同的阻塞方式适合不同场景。只要求程序永久挂起,select{} 或 nil 通道接收最简洁;要等待一组并发任务完成,sync.WaitGroup 最直观;要等待单个完成事件,done channel 更灵活;要响应操作系统退出信号,则应该使用 signal.Notify 配合通道接收。

需要警惕的是忙等误区。有些开发者会用 for{} 循环来“阻塞”主 Goroutine,这其实是在让 CPU 空转。一个空 for 循环会让一个核心使用率直接拉满,调度器也无法回收时间片。即使加上 runtime.Gosched() 也只能部分缓解,绝不能把它当作阻塞手段。time.Sleep 虽然会让出 CPU,但它只能等待固定时间,无法感知任务完成或外部事件,因此在正式代码中也不适合作为主要的阻塞方案。

最后还要分清阻塞与休眠的区别。真正的阻塞会让 Goroutine 从调度队列中移除,不消耗 CPU;休眠只是让 Goroutine 在计时器上等待,到期后继续运行。理解这一点,才能根据是否需要等待、等待什么条件,选出正确的阻塞方式,避免写出既占资源又难维护的并发代码。

Go阻塞Goroutineselect{}修改时间:2026-10-05 05:26:32

免责声明:已尽一切努力确保本网站所含信息的准确性。网站作品多为原创整理与精心创作,观点力求客观中立。本站旨在免费分享,内容仅供个人学习、研究或参考使用。若引用了第三方作品,版权归原作者所有。如内容涉及您的权益,请联系我们进行处理Email:chomcom@qq.com。
引用或转载本作品时,请注明当前出处:https://www.ipipp.com/html/1005/65863.html,基于非商业用途的前提下,欢迎转载或二创本作品。
内容垂直聚焦
专注技术核心技术栏目,确保每篇文章深度聚焦于实用技能。从代码技巧到架构设计,为用户提供无干扰的纯技术知识沉淀,精准满足专业提升需求。
知识结构清晰
覆盖从开发到部署的全链路。AI、前端、编程、数据库、服务器、建站、系统层层递进,构建清晰学习路径,帮助用户系统化掌握开发与运维所需的核心技术。
深度技术解析
拒绝泛泛而谈,深入技术细节与实践难点。无论是数据库优化还是服务器配置,均结合真实场景与代码示例进行剖析,致力于提供可直接应用于工作的解决方案。
专业领域覆盖
精准对应开发生命周期。从前端界面到后端编程,从数据库操作到服务器运维,形成完整闭环,一站式满足全栈工程师和运维人员的技术需求。
即学即用高效
内容强调实操性,步骤清晰、代码完整。用户可根据教程直接复现和应用于自身项目,显著缩短从学习到实践的距离,快速解决开发中的具体问题。
持续更新保障
专注既定技术方向进行长期、稳定的内容输出。确保各栏目技术文章持续更新迭代,紧跟主流技术发展趋势,为用户提供经久不衰的学习价值。