3.3 Worker

3.3.1 Worker介绍

Worker主要是用来执行一些需要在特定时间运行的业务逻辑。常见的使用场景,比如在后端服务定时同步数据。

3.3.2 配置规范

配置说明3.3 Worker - 图1

3.3.3 简单的Worker

参考Worker示例3.3 Worker - 图2

配置项

  1. [jupiter.cron.test]
  2. withSeconds = false
  3. concurrentDelay= "10s"
  4. immediatelyRun = false

任务逻辑

  1. func (eng *Engine) execJob() error {
  2. xlog.Info("info job")
  3. xlog.Warn("warn job")
  4. return nil
  5. }

设置任务

  1. func (eng *Engine) startJobs() error {
  2. cron := xcron.StdConfig("test").Build()
  3. cron.Schedule(xcron.Every(time.Second*10), xcron.FuncJob(eng.execJob))
  4. return eng.Schedule(cron)
  5. }