From 9d559b7d6c980cc1eb0eb3e58f6945a01633339a Mon Sep 17 00:00:00 2001 From: panlei <2799247126@qq.com> Date: 星期五, 06 十二月 2019 10:01:50 +0800 Subject: [PATCH] 使用dev配置文件 --- main.go | 23 +++++++++++------------ 1 files changed, 11 insertions(+), 12 deletions(-) diff --git a/main.go b/main.go index 11dbbb4..c20a2d4 100644 --- a/main.go +++ b/main.go @@ -3,7 +3,6 @@ import ( "flag" - "fmt" "sync" "net/http" _ "net/http/pprof" @@ -27,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,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(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) - Task(msg) + wg1.Add(1) + _ = p.Submit(syncCalculateSum) + //go Task(msg) } } } -- Gitblit v1.8.0