update new timer

Signed-off-by: Weizhen Wang <[email protected]>
pingcap · Apr 24, 2024 · eaaf8c9 · eaaf8c9
1 parent dc1492d
commit eaaf8c9
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/statistics/handle/syncload/stats_syncload.go b/pkg/statistics/handle/syncload/stats_syncload.go
@@ -83,11 +83,11 @@ func (s *statsSyncLoad) SendLoadRequests(sc *stmtctx.StatementContext, neededHis
 	sc.StatsLoad.Timeout = timeout
 	sc.StatsLoad.NeededItems = remainedItems
 	sc.StatsLoad.ResultCh = make([]<-chan singleflight.Result, 0, len(remainedItems))
-	timer := time.NewTimer(timeout)
-	defer timer.Stop()
 	for _, item := range remainedItems {
 		localItem := item
 		resultCh := globalStatsSyncLoadSingleFlight.DoChan(localItem.Key(), func() (any, error) {
+			timer := time.NewTimer(timeout)
+			defer timer.Stop()
 			task := &statstypes.NeededItemTask{
 				Item:      localItem,
 				ToTimeout: time.Now().Local().Add(timeout),