如何使用 github.com/robfig/cron 查找特定正在运行的 cron 作业？

使用 GitHub.com/robfig/cron 管理 cron 作业时，如果需要查找特定正在运行的作业，可以使用 Cron.Entry。该功能在 Cron v3 中提供，允许通过 entryID 检索和检查作业，包括删除作业以防止其再次运行。对于更复杂的作业或需要状态管理的情况，可以实现 Job 接口来定制作业行为。此外，还可以自定义时间表，通过实现 Schedule 接口来定义作业的触发时间。

我们如何在 github.com/robfig/cron 中查找特定正在运行的 cron 作业？

在通知服务中，我们将通知存储在数据库中，每个通知要么立即发送（给用户），要么按计划发送。

计划的任务是使用 cron 作业发送的。如果计划的通知在发送之前被删除，我们如何查找要删除的 cron 作业？

正确答案

有了 github.com/robfig/cron/v3，您就可以使用 Cron.Entry。

这是一个基本用法示例：

job := cron.funcjob(func() {
    fmt.println("hello cron")
})

c := cron.new(/* options */) 
entryid := c.schedule(cron.every(time.second*5), job)

// find the job entry
entry := c.entry(entryid)
// ... here you can inspect the job `entry`

// removes the entry, it won't run again
c.remove(entryid)

cron.FuncJob 实际上只是 func() 的包装。如果您需要更复杂的行为或状态，您可以自己实现 Job 接口：

type myjob struct{}

func (j *myjob) run() {
    fmt.println("foo")
}

然后您可以通过类型断言来获取作业的特定实例：

j := c.entry(id).job.(*myjob)
// ... do something with the *myjob instance

您还可以通过实现Schedule接口来自定义时间表：

type myschedule struct{}

// next returns the next activation time, later than the given time.
// next is invoked initially, and then each time the job is run.
func (s *myschedule) next(time.time) time.time {
    return time.now().add(time.second*5)
}

然后像这样使用它：

c := cron.New(/* options */) 
entryId := c.Schedule(&mySchedule{}, &myJob{})

如果您使用该软件包的早期版本，遗憾的是您无法通过 id 获取单个条目，并且 cron.schedule 也不分配 id。您必须自己管理查找表。如果可能，我建议升级到 v3。

今天关于《如何使用 github.com/robfig/cron 查找特定正在运行的 cron 作业？》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！