1 crontab 规则，设置脚本定时时间
Field name Mandatory? Allowed values Allowed special characters
---------- ---------- -------------- --------------------------
Seconds No 0-59 * / , -
Minutes Yes 0-59 * / , -
Hours Yes 0-23 * / , -
Day of month Yes 1-31 * / , - L W
Month Yes 1-12 or JAN-DEC * / , -
Day of week Yes 0-6 or SUN-SAT * / , - L #
Year No 1970–2099 * / , -例如
- 格式 秒 分 小时 天 月 星期(0代表星期天) 年
- */10 * * * * * * 每10s执行一次
- 20 30 3 * * * * 每天凌晨3点30分20s执行
- 15 0 0 * * 1 * 每周1凌晨0点0分15s执行
- 5 0 0,6,10,12,18 16-28 6 * 2021 2021年6月份 16号到28号(0,6,10,12,18点)0分5秒执行
2 示例代码
package xz_crontab
import (
"context"
"log"
"testing"
"time"
)
func Test_crontab(t *testing.T) {
jobs := []Job{
{
Name: "test",
Par: "1",
//CronExpr: "45 59 23 * * * *", // 23 点 59分 45 秒
CronExpr: "*/5 * * * * * *", // 5s执行一次
IsOpen: false, // true 开启脚本 false 关闭脚本
Callback: callback, // 设置你调用的函数
},
{
Name: "test2",
Par: "1",
//CronExpr: "45 59 23 * * * *", // 23 点 59分 45 秒
CronExpr: "*/11 * * * * * *", // 5s执行一次
IsOpen: false, // true 开启脚本 false 关闭脚本
Callback: callback, // 设置你调用的函数
},
{
Name: "test3",
Par: "1",
IsOpen: true, // true 开启脚本 false 关闭脚本
Callback: OnceTest2, // 设置你调用的函数
Once: true, // 只执行一次
},
}
model := InitCrontab(jobs)
go func() {
for {
select {
case timeDate := <-model.NextChGet():
log.Println("下次执行时间", timeDate)
}
}
}()
time.Sleep(20*time.Second)
model.Stop()
select {
}
}
func OnceTest(par ...interface{})(err error) {
log.Println("只执行一次")
return nil
}
func OnceTest2(par ...interface{})(err error) {
res := par[2].(context.Context)
for{
select {
case <-res.Done():
log.Println("停止了!")
return
default:
log.Println("只执行一次")
time.Sleep(time.Second)
}
}
return
}
func callback(par ...interface{})(err error ) {
log.Println("回调参数",par[0],par[1])
time.Sleep(6*time.Second)
return
}3.运行结果
