| | |
| | | logger.Info("-------------------------------------打印定时器元素当前值-----------------------------------------:", timeEle.N) |
| | | } |
| | | if timeEle.GroupId != "" && timeEle.N == 0{ |
| | | // 说明是联动任务的时间窗口 到点儿了该销毁了,再来了再开启 |
| | | // 说明是联动任务的时间窗口 到点儿了该销毁了,再来了再创建 |
| | | delete(TimeEleList,k) |
| | | } |
| | | } |
| | |
| | | TimeTicker() |
| | | } |
| | | |
| | | // 定时器单元 废弃版本 |
| | | // func TimeTicker() chan bool { |
| | | // logger.Info("执行了timeTicker") |
| | | // ticker := time.NewTicker(1 * time.Second) |
| | | // stopChan := make(chan bool) |
| | | // go func(ticker *time.Ticker) { |
| | | // defer ticker.Stop() |
| | | // for { |
| | | // select { |
| | | // case <-ticker.C: |
| | | // //logger.Info("执行单元", "计数器集合2", TimeEleList) |
| | | // for k, timeEle := range TimeEleList { |
| | | // timeEle.n = timeEle.n - 1 |
| | | // //logger.Info("遍历的数值", TimeEleList) |
| | | // if timeEle.n == 0 { |
| | | // // do something alarm |
| | | // alarm(k, timeEle) |
| | | // } |
| | | // } |
| | | // case stop := <-stopChan: |
| | | // if stop { |
| | | // logger.Info("定时器结束") |
| | | // return |
| | | // } |
| | | // } |
| | | // } |
| | | // }(ticker) |
| | | // return stopChan |
| | | // } |
| | | |
| | | // 结构体根据某字段排序 |
| | | type SubList []*RuleResult |