bingyi/gf
1
0
Fork 0
mirror of https://gitee.com/johng/gf synced 2026-06-06 02:25:47 +08:00
Code Issues Packages Projects Releases Wiki Activity

improve package gcron

Browse Source
This commit is contained in:
John Guo
2022-05-09 21:45:57 +08:00
parent 2e405342ca
commit cbff244d88
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
os/gcron/gcron_entry.go
View File

@ -78,7 +78,7 @@ func (c *Cron) doAddEntry(in doAddEntryInput) (*Entry, error) {
entry.timerEntry = gtimer.AddEntry(
in.Ctx,
time.Second,
entry.check,
entry.checkAndRun,
in.IsSingleton,
-1,
gtimer.StatusStopped,
@ -130,10 +130,10 @@ func (entry *Entry) Close() {
entry.timerEntry.Close()
}
// check is the core timing task check logic.
// checkAndRun is the core timing task check logic.
// The running times limits feature is implemented by gcron.Entry and cannot be implemented by gtimer.Entry.
// gcron.Entry relies on gtimer to implement a scheduled task check for gcron.Entry per second.
func (entry *Entry) check(ctx context.Context) {
func (entry *Entry) checkAndRun(ctx context.Context) {
if entry.schedule.meet(time.Now()) {
switch entry.cron.status.Val() {
case StatusStopped: