EasyNVR程序崩溃并报“Add called concurrently with Wait”

EasyNVR是TSINGSEE青犀视频比较热门的产品之一很多用于室内固定IP摄像头监控的场景都能够使用。有的开发者在使用之前可能会担心系统是否稳定?掉线是否频繁?是否支持设备重连?想了解一下的朋友们可以到我系统/运维们官网 easynvr.com 阅览也可以自主进下载试用。EasyNVR已经是一个非常成熟的系统运维包括哪些内容视频平台了,其他和其它的区别系统系统运维工程师面试问题及答案稳定,且支持二次开发,是很多视频业监控直播的不二之选。

在一个EasyNVR现场,出现程序崩溃的问其他垃圾题 Add called concurrentl程序崩溃一般是什原因y with Wait,对应日志如下:其他和其它的区别

根据崩溃日志查看,明显能够看出是 waitGroup 结构体已经处于 Wait() 状态,但是又调用了一次 wai系统运维工程师tGroup.Add() 方法导致程序崩溃。原始代码如下:

wg := sync.WaitGroup{}
for i := 0; i < runNumber; i++ {
go func(offlineChannel *channels.ChannelInfo) {
defer func() {
if p := recover(); p != nil {
log.Error("OfflineConnecting Connecting panic, %v", p)
log.Error("OfflineConnecting Connecting debug stack : %v", string(debug.Stack()))
}
wg.Done()
}()
wg.Add(1)
// 开始尝试连接设备 Connecting,连接完毕后,会异步上线
offlineChannel.Connecting()
}(offlineChannels[alreadyRunNumber])

alreadyRunNumber = alreadyRunNumber + 1
}
wg.Wait()

由程序看出,代码是在 go 协程中调用了 wg.Add(1) 方法,因此有可能在 wg.系统/运维Wait() 正在运行的时候出现 go吃鸡程序崩溃其他程中加一的操作,因此崩溃。

系统运维包括哪些内容 wg.Add() 不再协程中加一,代码如下:

wg := sync.WaitGroup{}
for i := 0; i < runNumber; i++ {
wg.Add(1)
go func(offlineChannel *channels.ChannelInfo) {
defer func() {
if p := recover(); p != nil {
log.Error("OfflineConnecting Connecting panic, %v", p)
log.Error("OfflineConnecting Connecting debug stack : %v", string(debug.Stack()))
}
wg.Done()
}()
// 开始尝试连接设备 Connecting,连接完毕后,会异步上线
offlineChannel.Connecting()
}(offlineChannels[alreadyRunNumber])

alreadyRunNumber = alreadyRunNumber + 1
}
wg.Wait()

wg.Add(1) 放在 go 程序外侧。修改后,代码即可成功运行。