func runGoroutine(f func()) {
maxRetry := 3
for i := 0; i < maxRetry+1; i++ {
go func() {
defer func() {
if err := recover(); err != nil && i < maxRetry {
log.Println(err)
utils.DingTalk(consts.WARN, err, true, "")
runGoroutine(f)
} else if err != nil {
// 处理重试多次仍失败的情况
log.Println("Failed to recover after multiple retries")
utils.DingTalk(consts.ERROR, "Failed to recover after multiple retries", true, "")
}
}()
f()
}()
}
}
这里我们使用一个计数器来限制最多重试3次，如果在执行过程中出现 panic，则递归调用 runGoroutine 函数再次尝试。当达到最大重试次数时，输出错误信息并停止重试。
