main.go
@@ -93,7 +93,7 @@ } else { //runtime.GOMAXPROCS(runtime.NumCPU()) //logger.Debug("使用的cpu个数:",runtime.NumCPU()) go func(msg []byte) { //go func(msg []byte) { logger.Debug("当前时间戳:", time.Now().Unix()) arg := structure.SdkDatas{} //paramFormat(msg, &arg) @@ -113,7 +113,7 @@ labelFilter.PushSomthing(resultMsg) //pushEnd := time.Since(start) //logger.Info("事件推送完所用时间:",ruleEnd,esEnd,pushEnd) }(msg) //}(msg) } } }