派生自 ruleprocess
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()