refactor: modify cycle task initialization to start immediately for score cleanup
This commit is contained in:
parent
df2ad0de94
commit
388cfdf377
@ -23,7 +23,7 @@ func init() {
|
|||||||
log.Print("连接 WebSocket 失败:", err)
|
log.Print("连接 WebSocket 失败:", err)
|
||||||
time.Sleep(time.Second)
|
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 {
|
func (bm *blScoresManager) connect() error {
|
||||||
|
@ -23,7 +23,7 @@ func init() {
|
|||||||
log.Print("连接 WebSocket 失败:", err)
|
log.Print("连接 WebSocket 失败:", err)
|
||||||
time.Sleep(time.Second)
|
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 {
|
func (sm *scoresManager) connect() error {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user