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