关掉多协程调测

panlei

2019-12-13 2ed59d1db29aa1a58f0cca02346eb7ae722eab27

关掉多协程调测

 main.go

@@ -78,20 +78,20 @@

func nRecvImpl(c deliver.Deliver, index int) {
    var msg []byte
    var wg1 sync.WaitGroup
    p,_ := ants.NewPool(20)
    syncCalculateSum := func() {
        Task(msg)
        wg1.Done()
    }
    wg1.Wait()
    //var wg1 sync.WaitGroup
    //p,_ := ants.NewPool(20)
    //syncCalculateSum := func() {
    //    Task(msg)
    //    wg1.Done()
    //}
    //wg1.Wait()
    var err error
    for {
        msg, err = c.Recv()
        if err == nil {
            wg1.Add(1)
            _ = p.Submit(syncCalculateSum)
            //go Task(msg)
            //wg1.Add(1)
            //_ = p.Submit(syncCalculateSum)
            Task(msg)
        } else {
            fmt.Println(err)
        }