From 1c3ea73677d2705782c65dbb7be45b9faa647418 Mon Sep 17 00:00:00 2001 From: panlei <2799247126@qq.com> Date: 星期四, 05 十二月 2019 18:33:02 +0800 Subject: [PATCH] ants协程池 --- main.go | 20 ++++++++++---------- 1 files changed, 10 insertions(+), 10 deletions(-) diff --git a/main.go b/main.go index 0450e64..935a091 100644 --- a/main.go +++ b/main.go @@ -75,20 +75,20 @@ func nRecvImpl(c deliver.Deliver, index int) { var msg []byte - //var wg1 sync.WaitGroup - //p,_ := ants.NewPool(100) - //syncCalculateSum := func() { - // Task(msg) - // wg1.Done() - //} - //wg1.Wait() + var wg1 sync.WaitGroup + p,_ := ants.NewPool(100) + 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) + //go Task(msg) } } } -- Gitblit v1.8.0