cpu火力全开

panlei

2019-08-09 a6a28e08a0031ca046947d67727f0e133c19e4ab

 main.go

@@ -6,6 +6,7 @@
   "basic.com/valib/deliver.git"
   "ruleprocess/insertdata"
   "ruleprocess/util"
   "runtime"
   "time"

   //"bufio"
@@ -22,11 +23,13 @@
   "ruleprocess/ruleserver"
   "sync"
)

var dbIp = flag.String("dbIp","127.0.0.1","dbserver ip")
var dbPort = flag.Int("dbPort",8001,"default dbPort=8001")
var surveyPort = flag.Int("surveyPort",40007,"survey port") //心跳
var pubPort = flag.Int("pubPort",50007,"pubsub port") //数据更新
var initchan = make(chan bool)

func init () {
   // 日志初始化
   logger.Config("./info.log", logger.DebugLevel)
@@ -70,7 +73,8 @@
            fmt.Println("recv error : ", err)
            continue
         } else {
            //for msg := range msgChan {
            runtime.GOMAXPROCS(runtime.NumCPU())
            logger.Debug("使用的cpu个数：",runtime.NumCPU())
               go func(msg []byte) {
                  logger.Debug("当前时间戳：",time.Now().Unix())
                  arg := ruleserver.SdkDatas{}
@@ -88,12 +92,12 @@
                  //事件推送
                  //go labelFilter.Judge(resultMsg)
               }(msg)
            //}
         }
      }
   }
}


// 将外部传进来的rect（top,bottom,left,right）转化为自己内部的rect(left top width height)
func rectFormat(rcobj *protomsg.Rect) ruleserver.Rect {
   //logger.Info("++++++++++++++++++++++++++++++收到的yolo的区域坐标：",rcobj)