zoukankan      html  css  js  c++  java
  • EasyNVR程序崩溃并报“Add called concurrently with Wait”

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

    在一个EasyNVR现场,出现程序崩溃的问题 Add called concurrently with Wait,对应日志如下:

    根据崩溃日志查看,明显能够看出是 waitGroup 结构体已经处于 Wait() 状态,但是又调用了一次 waitGroup.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 程序外侧。修改后,代码即可成功运行。

  • 相关阅读:
    Ajax(三)
    Ajax(二)
    Django(四)
    Ajax(一)
    Django(三)
    Django(二)
    Django(一)
    Http协议
    Bootstrap
    python 绑定方法
  • 原文地址:https://www.cnblogs.com/EasyNVR/p/15724503.html
Copyright © 2011-2022 走看看