test/gf
1
0
Fork 0
mirror of https://gitee.com/johng/gf.git synced 2024-11-30 03:07:45 +08:00
Code Issues Actions 15 Packages Projects Releases Wiki Activity

improve package gcron/gtimer

Browse Source
This commit is contained in:
John Guo 2022-01-20 15:53:16 +08:00
parent 7401fb09c9
commit 619e256138
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
os/gcron/gcron_entry.go
View File

@ -172,10 +172,11 @@ func (entry *Entry) check(ctx context.Context) {
}
entry.logDebugf(ctx, "[gcron] %s %s start", entry.schedule.pattern, entry.jobName)
entry.Job(entry.timerEntry.Ctx())
entry.Job(ctx)
}
}
}
func (entry *Entry) logDebugf(ctx context.Context, format string, v ...interface{}) {
if logger := entry.cron.GetLogger(); logger != nil {
logger.Debugf(ctx, format, v...)

2
os/gtimer/gtimer_entry.go
View File

@ -16,7 +16,7 @@ import (
// Entry is the timing job.
type Entry struct {
job JobFunc // The job function.
ctx context.Context // The context for the job.
ctx context.Context // The context for the job, for READ ONLY.
timer *Timer // Belonged timer.
ticks int64 // The job runs every tick.
times *gtype.Int // Limit running times.