statstics: trigger evict by the timer (#58027)

close #58052

Author: hawkingrei

pkg/domain/domain.go

@@ -2718,6 +2718,7 @@ func (do *Domain) updateStatsWorker(_ sessionctx.Context) {
 			}
 		case <-readMemTicker.C:
 			memory.ForceReadMemStats()
+			do.StatsHandle().StatsCache.TriggerEvict()
 		case <-updateStatsHealthyTicker.C:
 			statsHandle.UpdateStatsHealthyMetrics()
 		}

pkg/statistics/handle/cache/internal/inner.go

@@ -41,4 +41,6 @@ type StatsCacheInner interface {
 	SetCapacity(int64)
 	// Close stops the cache
 	Close()
+	// TriggerEvict triggers the cache to evict some items
+	TriggerEvict()
 }

pkg/statistics/handle/cache/internal/lfu/lfu_cache.go

@@ -251,3 +251,8 @@ func (s *LFU) addCost(v int64) {
 	newv := s.cost.Add(v)
 	metrics.CostGauge.Set(float64(newv))
 }
+
+// TriggerEvict implements statsCacheInner
+func (s *LFU) TriggerEvict() {
+	s.triggerEvict()
+}

pkg/statistics/handle/cache/internal/mapcache/map_cache.go

@@ -131,3 +131,6 @@ func (*MapCache) SetCapacity(int64) {}
 
 // Close implements StatsCacheInner
 func (*MapCache) Close() {}
+
+// TriggerEvict implements statsCacheInner
+func (*MapCache) TriggerEvict() {}

pkg/statistics/handle/cache/statscache.go

@@ -259,6 +259,11 @@ func (s *StatsCacheImpl) Put(id int64, t *statistics.Table) {
 	s.Load().put(id, t)
 }
 
+// TriggerEvict triggers the cache to evict some items.
+func (s *StatsCacheImpl) TriggerEvict() {
+	s.Load().TriggerEvict()
+}
+
 // MaxTableStatsVersion returns the version of the current cache, which is defined as
 // the max table stats version the cache has in its lifecycle.
 func (s *StatsCacheImpl) MaxTableStatsVersion() uint64 {

pkg/statistics/handle/cache/statscacheinner.go

@@ -183,3 +183,8 @@ func (sc *StatsCache) Update(tables []*statistics.Table, deletedIDs []int64, ski
 		}
 	}
 }
+
+// TriggerEvict triggers the cache to evict some items.
+func (sc *StatsCache) TriggerEvict() {
+	sc.c.TriggerEvict()
+}

pkg/statistics/handle/types/interfaces.go

@@ -260,6 +260,9 @@ type StatsCache interface {
 
 	// UpdateStatsHealthyMetrics updates stats healthy distribution metrics according to stats cache.
 	UpdateStatsHealthyMetrics()
+
+	// TriggerEvict triggers the cache to evict some items
+	TriggerEvict()
 }
 
 // StatsLockTable is the table info of which will be locked.