| | |
| | | package ruleserver |
| | | |
| | | import ( |
| | | "fmt" |
| | | "ruleprocess/logger" |
| | | "time" |
| | | ) |
| | |
| | | |
| | | func TimeTicker() { |
| | | logger.Info("定时器执行了") |
| | | fmt.Println("定时器执行了") |
| | | ticker := time.NewTicker(1 * time.Second) |
| | | go func(ticker *time.Ticker) { |
| | | defer ticker.Stop() |
| | | for { |
| | | select { |
| | | case <-ticker.C: |
| | | logger.Info("定时器执行单元") |
| | | logger.Info("定时器执行单元",time.Now().Unix()) |
| | | fmt.Println("定时器执行单元",time.Now().Unix()) |
| | | // 每秒钟计数器池子里所有的计数器元素都减一,减到0的是该报警的 |
| | | for _, timeEle := range TimeEleList { |
| | | if timeEle.N > 0 { |
| | |
| | | case stop := <-stopChan: |
| | | if stop { |
| | | logger.Info("定时器结束") |
| | | return |
| | | //os.Exit(0) |
| | | } |
| | | } |