ruleserver/timeTicker.go
@@ -32,8 +32,6 @@ } func TimeTicker() { logger.Info("定时器执行了") fmt.Println("定时器执行了") ticker := time.NewTicker(1 * time.Second) go func(ticker *time.Ticker) { defer ticker.Stop() @@ -115,10 +113,12 @@ delete(TimeEleList, k) } else { if timeEle.BufferFlag > 0 { logger.Debug("缓冲区减减") timeEle.BufferFlag-- } } } else { logger.Debug("-----------结果为假且不到0,杀死定时器") delete(TimeEleList, k) } }