Skip to content

Commit 31c7fd1

Browse files
committed
🐛 Fix cron job setup #14817
1 parent 7120e1e commit 31c7fd1

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
lines changed

kernel/job/cron.go

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,16 @@ func StartCron() {
5252

5353
func every(interval time.Duration, f func(), name ...string) {
5454
util.RandomSleep(50, 200)
55+
56+
// 启动后立即执行一次
57+
func() {
58+
defer logging.Recover()
59+
f()
60+
if 0 < len(name) {
61+
logging.LogInfof("cron job [%s] executed", name)
62+
}
63+
}()
64+
5565
ticker := time.NewTicker(interval)
5666
defer ticker.Stop()
5767
for range ticker.C {

0 commit comments

Comments
 (0)