From c4bfea06be1257db43f54708fd12330b52b44ced Mon Sep 17 00:00:00 2001
From: panlei <2799247126@qq.com>
Date: 星期五, 06 十二月 2019 18:08:57 +0800
Subject: [PATCH] ---

---
 main.go |    4 ++--
 1 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/main.go b/main.go
index 935a091..c20a2d4 100644
--- a/main.go
+++ b/main.go
@@ -26,7 +26,7 @@
 var surveyPort = flag.Int("surveyPort", 40007, "survey port") //蹇冭烦
 var pubPort = flag.Int("pubPort", 50007, "pubsub port")       //鏁版嵁鏇存柊
 var initchan = make(chan bool)
-var env =  flag.String("env","pro","env set")
+var env =  flag.String("env","dev","env set")
 
 func init() {
 	flag.Parse()
@@ -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()

--
Gitblit v1.8.0