瀏覽代碼

feat:重置定时器

wangshan 1 年之前
父節點
當前提交
461f2b43e9
共有 1 個文件被更改,包括 2 次插入1 次删除
  1. 2 1
      internal/dao/internal/userTask.go

+ 2 - 1
internal/dao/internal/userTask.go

@@ -93,7 +93,8 @@ func (ut *UserTask) Run() {
 		}
 		}
 		select {
 		select {
 		case info := <-ut.PInfo:
 		case info := <-ut.PInfo:
-			ut.Ticker.Reset(time.Duration(do.TaskConfig.UserTask.Ticker) * time.Second)
+			ut.Ticker.Stop()
+			ut.Ticker = time.NewTicker(time.Duration(do.TaskConfig.UserTask.Ticker) * time.Second)
 			//项目信息匹配
 			//项目信息匹配
 			if ut.MatchConditions(info) {
 			if ut.MatchConditions(info) {
 				ut.CalculateLock.Lock()
 				ut.CalculateLock.Lock()