企业🤖AI Agent构建引擎,智能编排和调试,一键部署,支持私有化部署方案 广告
[TOC] # 简介 我们经常需要让主 goroutine 处于永久阻塞状态,这样其他的 gorotine 就可以一直运行处理信息。下面我总结了几种可以实现永久阻塞的方法,其中大部分实例代码无法直接运行,因为 Go runtime 会检查所有 goroutine 并提示所有的 goroutine 都处于 deadlock,在实际使用中,我们添加具体的业务 goroutien 就可以运行了。 # 死循环 说到永久阻塞第一个想到的应该就是死循环。 ~~~ package main func main() { for {} } ~~~ 死循环虽然可以实现永久阻塞,但是对于 Go 而言,for 死循环所在的 goroutine 还是一直处于“运行”状态,所以死循环会消耗一定的 CPU,不推荐使用。 # `sync.Mutex` 使用锁,我们可以对已经锁了的锁,再次申请锁。 ~~~ package main import ( "sync" ) func main() { var lock sync.Mutex lock.Lock() lock.Lock() } ~~~ 该实例代码会提示死锁。不推荐使用。 # sync.WaitGroup 一个不会减少的 WaitGroup 就实现了永久阻塞 ~~~ package main import "sync" func main() { var wg sync.WaitGroup wg.Add(1) wg.Wait() } ~~~ 该实例代码会提示死锁。 # select 空 select 会一直阻塞 ~~~ package main func main() { select{} } ~~~ 该实例代码会提示死锁。 # channel 使用 channel 本身会一直阻塞直到接收到信息。 ~~~ package main func main() { c := make(chan struct{}) <-c } ~~~ nil channel 会永久阻塞 ~~~ package main func main() { var c chan struct{} <-c } ~~~ # os.Signal 使用信号量配合 channel 实现永久阻塞 ~~~ package main import ( "os" "os/signal" "syscall" ) func main() { sig := make(chan os.Signal, 1) signal.Notify(sig, syscall.SIGUSR2) <-sig } ~~~ 这样只有当我们传递 SIGUSR2 信号(`kill -USR2 [pid]`)的时候阻塞才会停止。sig 要设置为可缓冲的 channel,或者可能如果 goroutine 没有准备好信号会被丢弃。