| | |
| | | } |
| | | |
| | | func TimeTicker() { |
| | | logger.Info("定时器执行了") |
| | | fmt.Println("定时器执行了") |
| | | ticker := time.NewTicker(1 * time.Second) |
| | | go func(ticker *time.Ticker) { |
| | | defer ticker.Stop() |
| | |
| | | var flagTime string // |
| | | // 判断有无此规则组的定时器 |
| | | flag := false |
| | | rw.Lock() |
| | | for k, _ := range TimeEleList { |
| | | //logger.Debug("-----------------看看这个key和groupId", k, groupId) |
| | | if strings.Contains(k, groupId) && k != groupId{ |
| | |
| | | delete(TimeEleList, k) |
| | | } else { |
| | | if timeEle.BufferFlag > 0 { |
| | | logger.Debug("缓冲区减减") |
| | | timeEle.BufferFlag-- |
| | | } |
| | | } |
| | | } else { |
| | | logger.Debug("-----------结果为假且不到0,杀死定时器") |
| | | delete(TimeEleList, k) |
| | | } |
| | | } |
| | |
| | | flagTime = "00" |
| | | } |
| | | } |
| | | rw.Unlock() |
| | | return flagTime |
| | | } |
| | | |