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