gpt4 book ai didi

依赖轮询器一直运行的Go应用,保证其稳定性的建议

转载 作者:IT王子 更新时间:2023-10-29 02:01:04 25 4
gpt4 key购买 nike

所以我的应用程序依赖于每 x 秒轮询一次的 goroutine。

func main() {
// ...
go p.StartPoller();
}

有哪些提示可确保此轮询器始终运行?

我只是厌倦了一些事情,也许是因为我没有完全理解 go 中错误捕获的概念。由于错误是值,并且假设我没有或我使用的任何库调用 panic(),并且没有空指针引用或数组越界此 goroutine 内的任何代码都不应使 goroutine 正确崩溃 ?

func (p *Poller) StartPoller() {
ticker := time.NewTicker(3 * time.Second)
defer ticker.Stop()

for {
<-ticker.C
// code here
}

}

最佳答案

你是对的,你发布的代码不应该崩溃并因此“崩溃”goroutine。

作为最佳实践,要确保 //code here 也不会这样做,请将其“包装”在函数(匿名或命名函数)中,然后使用 recover( )(延迟!)。这将确保轮询任务也永远不会“崩溃”轮询调度程序。

像这样:

func (p *Poller) StartPoller() {
ticker := time.NewTicker(3 * time.Second)
defer ticker.Stop()

for {
<-ticker.C

func() {
defer func() {
if r := recover(); r != nil {
fmt.Println("Recovered: %v", r)
}
}()

// code here
// If this would panic, it will be recovered...
}()
}
}

即使轮询器要一直运行,我仍然会向它添加一个“关闭” channel ,以提供优雅终止的可能性:

func (p *Poller) StartPoller(shutdown <-chan struct{}) {
ticker := time.NewTicker(3 * time.Second)
defer ticker.Stop()

for {
select {
case <-ticker.C:
case <-shutdown:
return
}

func() {
defer func() {
if r := recover(); r != nil {
fmt.Println("Recovered: %v", r)
}
}()

// code here
// If this would panic, it will be recovered...
}()
}
}

关于依赖轮询器一直运行的Go应用,保证其稳定性的建议,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/54026549/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com