---

panlei

2019-12-06 c4bfea06be1257db43f54708fd12330b52b44ced

 main.go

@@ -26,7 +26,7 @@
var surveyPort = flag.Int("surveyPort", 40007, "survey port") //心跳
var pubPort = flag.Int("pubPort", 50007, "pubsub port")       //数据更新
var initchan = make(chan bool)
var env =  flag.String("env","pro","env set")
var env =  flag.String("env","dev","env set")

func init() {
   flag.Parse()
@@ -76,7 +76,7 @@
func nRecvImpl(c deliver.Deliver, index int) {
   var msg []byte
   var wg1 sync.WaitGroup
   p,_ := ants.NewPool(100)
   p,_ := ants.NewPool(20)
   syncCalculateSum := func() {
      Task(msg)
      wg1.Done()