panlei
2019-12-05 a5dec478e435f4fd1662c651c9904c0648da5655
main.go
@@ -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()