Method cleanup

server/ratelimit/limiter.go:261–279

cleanup 清理过期的窗口

()

// cleanup 清理过期的窗口
func (l *SlidingWindowLimiter) cleanup() {
	ticker := time.NewTicker(l.window)
	defer ticker.Stop()

	for range ticker.C {
		l.mu.Lock()
		now := time.Now()
		cutoff := now.Add(-l.window * 2)

		for key, w := range l.windows {
			w.mu.Lock()
			if len(w.requests) == 0 || (len(w.requests) > 0 && w.requests[len(w.requests)-1].Before(cutoff)) {
				delete(l.windows, key)
			}
			w.mu.Unlock()
		}
		l.mu.Unlock()
	}
}