From 388cfdf377b26946cc511a7c8bfd425290c7a9bd Mon Sep 17 00:00:00 2001 From: lixiangwuxian Date: Sat, 22 Feb 2025 18:16:54 +0800 Subject: [PATCH] refactor: modify cycle task initialization to start immediately for score cleanup --- service/beatleader/hot.go | 2 +- service/scoresaber/hot.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/service/beatleader/hot.go b/service/beatleader/hot.go index d1c4420..f5833b5 100644 --- a/service/beatleader/hot.go +++ b/service/beatleader/hot.go @@ -23,7 +23,7 @@ func init() { log.Print("连接 WebSocket 失败:", err) time.Sleep(time.Second) } - util.AddCycleTask("cleanOldScores", 1*time.Hour, 1*time.Hour, cleanOldScores) + util.AddCycleTask("cleanOldScores", 0, 1*time.Hour, cleanOldScores) } func (bm *blScoresManager) connect() error { diff --git a/service/scoresaber/hot.go b/service/scoresaber/hot.go index 03ec36f..101efbe 100644 --- a/service/scoresaber/hot.go +++ b/service/scoresaber/hot.go @@ -23,7 +23,7 @@ func init() { log.Print("连接 WebSocket 失败:", err) time.Sleep(time.Second) } - util.AddCycleTask("cleanOldScores", 1*time.Hour, 1*time.Hour, cleanOldScores) + util.AddCycleTask("cleanOldScores", 0, 1*time.Hour, cleanOldScores) } func (sm *scoresManager) connect() error {