panlei
2019-07-05 1139cf035510604c7e38638a4e47485fef4ffa77
timeticker的fmt改为logger
1个文件已修改
15 ■■■■ 已修改文件
ruleserver/timeTicker.go 15 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
ruleserver/timeTicker.go
@@ -1,7 +1,6 @@
package ruleserver
import (
    "fmt"
    "ruleprocess/logger"
    "time"
)
@@ -27,14 +26,14 @@
}
func TimeTicker() {
    fmt.Println("定时器执行了")
    logger.Info("定时器执行了")
    ticker := time.NewTicker(1 * time.Second)
    go func(ticker *time.Ticker) {
        defer ticker.Stop()
        for {
            select {
            case <-ticker.C:
                fmt.Println("定时器执行单元")
                logger.Info("定时器执行单元")
                // 每秒钟计数器池子里所有的计数器元素都减一,减到0的是该报警的
                for _, timeEle := range TimeEleList {
                    if timeEle.N > 0 {
@@ -44,7 +43,7 @@
                }
            case stop := <-stopChan:
                if stop {
                    fmt.Println("定时器结束")
                    logger.Info("定时器结束")
                    //os.Exit(0)
                }
            }
@@ -58,7 +57,7 @@
// 定时器单元  废弃版本
// func TimeTicker() chan bool {
//     fmt.Println("执行了timeTicker")
//     logger.Info("执行了timeTicker")
//     ticker := time.NewTicker(1 * time.Second)
//     stopChan := make(chan bool)
//     go func(ticker *time.Ticker) {
@@ -66,10 +65,10 @@
//         for {
//             select {
//             case <-ticker.C:
//                 //fmt.Println("执行单元", "计数器集合2", TimeEleList)
//                 //logger.Info("执行单元", "计数器集合2", TimeEleList)
//                 for k, timeEle := range TimeEleList {
//                     timeEle.n = timeEle.n - 1
//                     //fmt.Println("遍历的数值", TimeEleList)
//                     //logger.Info("遍历的数值", TimeEleList)
//                     if timeEle.n == 0 {
//                         // do something alarm
//                         alarm(k, timeEle)
@@ -77,7 +76,7 @@
//                 }
//             case stop := <-stopChan:
//                 if stop {
//                     fmt.Println("定时器结束")
//                     logger.Info("定时器结束")
//                     return
//                 }
//             }