给定时器加锁

panlei

2019-09-18 c6bc736739b2f95c9c9717127c6aad66bb8068d5

给定时器加锁

 ruleserver/timeTicker.go

@@ -41,6 +41,7 @@
                logger.Info("定时器执行单元", time.Now().Unix())
                fmt.Println("定时器执行单元", time.Now().Unix())
                // 每秒钟计数器池子里所有的计数器元素都减一，减到0的是该报警的
                rw.Lock()
                for k, timeEle := range TimeEleList {
                    if timeEle.N > 0 {
                        timeEle.N = timeEle.N - 1
@@ -51,6 +52,7 @@
                        delete(TimeEleList, k)
                    }
                }
                rw.Unlock()
            case stop := <-stopChan:
                if stop {
                    logger.Info("定时器结束")