
本文介绍了在 Go 语言中永久阻塞 Goroutine 的两种方法。一种是使用 sync.WaitGroup 等待所有子 Goroutine 完成,另一种是利用 select {} 语句无限期阻塞当前 Goroutine。针对不需要结果的场景,select {} 提供了一种更简洁的解决方案。
在 Go 语言中,有时我们需要阻塞一个 Goroutine,使其在后台持续运行。常见的场景是启动多个 Goroutine 提供后台服务,而主 Goroutine 则需要保持运行状态以维持程序的生命周期。本文将介绍两种在 Go 语言中永久阻塞 Goroutine 的方法。
方法一:使用 sync.WaitGroup
sync.WaitGroup 是 Go 语言标准库 sync 包提供的一种同步机制,用于等待一组 Goroutine 完成。虽然它的主要目的是等待 Goroutine 完成,但我们也可以利用它来实现阻塞主 Goroutine 的效果。
package main
import (
"fmt"
"sync"
"time"
)
func worker(id int, wg *sync.WaitGroup) {
defer wg.Done() // Goroutine 完成时调用 Done()
fmt.Printf("Worker %d starting\n", id)
time.Sleep(time.Second * 2) // 模拟工作
fmt.Printf("Worker %d done\n", id)
}
func main() {
var wg sync.WaitGroup
// 启动多个 worker Goroutine
for i := 1; i <= 3; i++ {
wg.Add(1) // 启动一个 Goroutine 前调用 Add(1)
go worker(i, &wg)
}
wg.Wait() // 等待所有 Goroutine 完成
fmt.Println("All workers done")
}代码解释:
- sync.WaitGroup 的 Add(delta int) 方法用于增加计数器,表示需要等待的 Goroutine 数量。
- sync.WaitGroup 的 Done() 方法用于减少计数器,通常在 Goroutine 完成时调用。
- sync.WaitGroup 的 Wait() 方法会阻塞,直到计数器变为 0,表示所有 Goroutine 都已完成。
注意事项:
虽然 sync.WaitGroup 可以实现阻塞效果,但它的主要目的是等待 Goroutine 完成。如果仅仅是为了阻塞主 Goroutine,而不关心子 Goroutine 的结果,那么使用 select {} 会更加简洁。
方法二:使用 select {}
select 语句用于在多个 channel 操作中进行选择。如果 select 语句没有任何 case,它会永久阻塞。
package main
import (
"fmt"
"time"
)
func backgroundTask() {
for {
fmt.Println("Background task running...")
time.Sleep(time.Second)
}
}
func main() {
go backgroundTask() // 启动后台任务
select {} // 永久阻塞主 Goroutine
}代码解释:
select {} 语句没有任何 case,因此它会无限期地等待,从而阻塞主 Goroutine。
注意事项:
- select {} 会永久阻塞当前 Goroutine,直到程序被强制终止。
- 使用 select {} 可以确保主 Goroutine 不会退出,从而保持程序的运行状态。
- select {} 会将控制权让给其他 Goroutine,确保它们能够正常运行。
总结:
对于需要在后台运行 Goroutine 并永久阻塞主 Goroutine 的场景,select {} 是一种简单有效的解决方案。它避免了使用 channel 或循环睡眠等复杂的方法,并且能够保证程序的正常运行。 在不需要结果的场景下,推荐使用 select {}。 如果需要等待其他goroutine完成,则使用sync.WaitGroup。










