From 302d2934b0950ac6cc509ca099fa9d9cc2e5b17b Mon Sep 17 00:00:00 2001
From: panlei <2799247126@qq.com>
Date: 星期五, 09 八月 2019 16:37:32 +0800
Subject: [PATCH] ---
---
main.go | 11 +++++------
ruleserver/timeTicker.go | 4 ++--
2 files changed, 7 insertions(+), 8 deletions(-)
diff --git a/main.go b/main.go
index 8969110..cd9cca7 100644
--- a/main.go
+++ b/main.go
@@ -6,7 +6,6 @@
"basic.com/valib/deliver.git"
"ruleprocess/insertdata"
"ruleprocess/util"
- "runtime"
"time"
//"bufio"
@@ -73,10 +72,10 @@
fmt.Println("recv error : ", err)
continue
} else {
- runtime.GOMAXPROCS(runtime.NumCPU())
- logger.Debug("浣跨敤鐨刢pu涓暟锛�",runtime.NumCPU())
- go func(msg []byte) {
- logger.Debug("褰撳墠鏃堕棿鎴筹細", time.Now().Unix())
+ //runtime.GOMAXPROCS(runtime.NumCPU())
+ //logger.Debug("浣跨敤鐨刢pu涓暟锛�",runtime.NumCPU())
+ //go func(msg []byte) {
+ //logger.Debug("褰撳墠鏃堕棿鎴筹細", time.Now().Unix())
arg := ruleserver.SdkDatas{}
//paramFormat(msg, &arg)
start := time.Now()
@@ -91,7 +90,7 @@
logger.Debug("鎻掑叆瀹孍s鎵�鐢ㄦ椂闂达細", time.Since(start))
//浜嬩欢鎺ㄩ��
//go labelFilter.Judge(resultMsg)
- }(msg)
+ //}(msg)
}
}
}
diff --git a/ruleserver/timeTicker.go b/ruleserver/timeTicker.go
index e6219ed..2449663 100644
--- a/ruleserver/timeTicker.go
+++ b/ruleserver/timeTicker.go
@@ -32,8 +32,8 @@
}
func TimeTicker() {
- logger.Info("瀹氭椂鍣ㄦ墽琛屼簡")
- fmt.Println("瀹氭椂鍣ㄦ墽琛屼簡")
+ //logger.Info("瀹氭椂鍣ㄦ墽琛屼簡")
+ //fmt.Println("瀹氭椂鍣ㄦ墽琛屼簡")
ticker := time.NewTicker(1 * time.Second)
go func(ticker *time.Ticker) {
defer ticker.Stop()
--
Gitblit v1.8.0