
goroutine 如何确保持续运行?
在提供的代码中,newclientcodec() 返回一个 client 对象,该对象启动一个 goroutine 来接受请求:go client.receive()。
这个问题的重点是,主线程执行完后,goroutine 如何保持运行。
答案很简单,只要主线程的生命周期比 goroutine 长即可。这里有几个方法可以实现这一点:
方法 1:阻塞主线程
主线程可以通过阻塞在信号或其他输入上,例如:
import (
"os"
"os/signal"
"syscall"
)
func main() {
newClientCodec(...)
ch := make(chan os.Signal, 1)
signal.Notify(ch, syscall.SIGINT)
<-ch
}方法 2:使用 sync.waitgroup
主线程可以通过使用 sync.waitgroup,等待 goroutine 完成工作。
方法 3:利用网络 api 阻塞
如果主线程调用了 listen 等阻塞式的网络 api,那么它将自然地保持运行,直到 goroutine 完成。
优雅地关闭
对于某些情况,例如需要在主线程退出前保存数据,主线程必须优雅地关闭。
在这种情况下,可以使用信号处理、context 或 sync.waitgroup 来允许 goroutine 完成工作,然后主线程才能退出。









