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