main.go | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
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()