ruleserver/timeTicker.go
@@ -1,6 +1,7 @@ package ruleserver import ( "fmt" "ruleprocess/logger" "time" ) @@ -27,7 +28,7 @@ func TimeTicker() { logger.Info("定时器执行了") //fmt.Println("定时器执行了") fmt.Println("定时器执行了") ticker := time.NewTicker(1 * time.Second) go func(ticker *time.Ticker) { defer ticker.Stop() @@ -35,7 +36,7 @@ select { case <-ticker.C: logger.Info("定时器执行单元") //fmt.Println("定时器执行单元") fmt.Println("定时器执行单元") // 每秒钟计数器池子里所有的计数器元素都减一,减到0的是该报警的 for _, timeEle := range TimeEleList { if timeEle.N > 0 {