crontab := cron.New(cron.WithSeconds())
task :=
func
()
{
fmt.Println(
"hello world"
, time.Now())
spec :=
"*/5 * * * * ?"
crontab.AddFunc(spec, task)
crontab.Start()
select
{}
------------------------------------------输出结果----------------------------------
hello world
2020
-03
-18
11
:
13
:
00.0241639
+
0800
CST m=+
3.113746301
hello world
2020
-03
-18
11
:
13
:
05.0007375
+
0800
CST m=+
8.090319901
hello world
2020
-03
-18
11
:
13
:
10.0004232
+
0800
CST m=+
13.090005601
hello world
2020
-03
-18
11
:
13
:
15.0003857
+
0800
CST m=+
18.089968101
hello world
2020
-03
-18
11
:
13
:
20.0003788
+
0800
CST m=+
23.089961201
3 Cron 表达式
cron
表达式是一个好东西，这个东西不仅
Java
的
quartZ
能用到，
Go
语言中也可以用到。我没有用过
Linux的cron
，但网上说
Linux
也是可以用
crontab -e
命令来配置定时任务。
Go
语言和
Java
中都是可以精确到秒的，但是
Linux
中不行。
cron
表达式代表一个时间的集合，使用6个空格分隔的字段表示：
|
字段名
|
是否必须
|
允许的值
|
允许的特定字符
|
|
秒(Seconds)
|
是
|
0-59
|
* / , -
|
|
分(Minute)
|
是
|
0-59
|
* / , -
|
|
时(Hours)
|
是
|
0-23
|
* / , -
|
|
日(Day of month)
|
是
|
1-31
|
* / , - ?
|
|
月(Month)
|
是
|
1-12 或 JAN-DEC
|
* / , -
|
|
星期(Day of week)
|
否
|
0-6 或 SUM-SAT
|
* / , - ?
|
3.1 Corn表达式说明
月(Month)和星期(Day of week)字段的值不区分大小写，如：SUN、Sun 和 sun 是一样的。
星期(Day of week)字段如果没提供，相当于是 *
3.2 Corn表达式示例说明
如果我们使用
crontab := cron.New(cron.WithSeconds())
,
比如我们传递了一个字符串是：
"* * * * * *"
在
crontab.AddFunc()
的第一个参数，这六个
*
是指什么呢？
如果是用
crontab := cron.New()
则只需要五个
*
,如
* * * * *
┌─────────────second 范围 (0 - 60)
│ ┌───────────── min (0 - 59)
│ │ ┌────────────── hour (0 - 23)
│ │ │ ┌─────────────── day of month (1 - 31)
│ │ │ │ ┌──────────────── month (1 - 12)
│ │ │ │ │ ┌───────────────── day of week (0 - 6) (0 to 6 are Sunday to
│ │ │ │ │ │ Saturday)
│ │ │ │ │ │
│ │ │ │ │ │
* * * * * *
3.3 cron特定字符说明
| 符号 | 说明 |
|---|
| (*) | 表示 cron 表达式能匹配该字段的所有值。如在第5个字段使用星号(month)，表示每个月 |
| (/) | 表示增长间隔，如第1个字段(minutes) 值是 3-59/15，表示每小时的第3分钟开始执行一次，之后每隔 15 分钟执行一次（即 3、18、33、48 这些时间点执行），这里也可以表示为：3/15 |
| (,) | 用于枚举值，如第6个字段值是 MON,WED,FRI，表示 星期一、三、五 执行 |
| (-) | 表示一个范围，如第3个字段的值为 9-17 表示 9am 到 5pm 直接每个小时（包括9和17） |
| (?) | 只用于 日(Day of month) 和 星期(Day of week)，表示不指定值，可以用于代替 * |
3.4 常用cron举例
每隔5秒执行一次：*/5 * * * * ?
每隔1分钟执行一次：0 */1 * * * ?
每天23点执行一次：0 0 23 * * ?
每天凌晨1点执行一次：0 0 1 * * ?
每月1号凌晨1点执行一次：0 0 1 1 * ?
每周一和周三晚上22:30: 00 30 22 * * 1,3
在26分、29分、33分执行一次：0 26,29,33 * * * ?
每天的0点、13点、18点、21点都执行一次：0 0 0,13,18,21 * * ?
每年三月的星期四的下午14:10和14:40: 00 10,40 14 ? 3 4
3.5 预定义的时间格式
您可以使用几个预定义的表达式来代替上表的表达式,使用如下
| 输入 | 描述 | 等式 |
|---|
@yearly (or @annually) | 每年1月1日午夜跑步一次 | 0 0 0 1 1 * |
@monthly | 每个月第一天的午夜跑一次 | 0 0 0 1 * * |
@weekly | 每周周六的午夜运行一次 | 0 0 0 * * 0 |
@daily (or @midnight) | 每天午夜跑一次 | 0 0 0 * * * |
@hourly | 每小时运行一次 | 0 0 * * * * |
@every <duration> | every duration | |
c := cron.New()
c.AddFunc("@every 1h30m", func() { fmt.Println("Every hour thirty") })
4 多个定时任务
package main
import (
"fmt"
"github.com/robfig/cron/v3"
"time"
type TestTask struct {
Name string
func (t *TestTask) Run() {
fmt.Println("TestTask", t.Name)
type Test2Task struct {
Name string
func (t *Test2Task) Run() {
fmt.Println("Test2Task", t.Name)
func main() {
crontab := cron.New(cron.WithSeconds())
spec := "*/5 * * * * ?"
task := func() {
fmt.Println("hello world", time.Now())
crontab.AddFunc(spec, task)
crontab.AddJob(spec, &TestTask{Name: "tom"})
crontab.AddJob(spec, &Test2Task{Name: "jeck"})
crontab.Start()
defer crontab.Stop()
select {}
--------------------------------------输出结果----------------------------------------
TestTask tom
Test2Task jeck
hello world 2020-03-18 13:22:10.0245997 +0800 CST m=+2.761856801
TestTask tom
Test2Task jeck
hello world 2020-03-18 13:22:15.0008245 +0800 CST m=+7.738081601
……………………………………
5 主要类型或接口说明
5.1 Cron
Cron：包含一系列要执行的实体；支持暂停【stop】；添加实体等
Cron 结构没有导出任何成员。
有一个成员stop，类型是struct{}，即空结构体。
type Cron struct {
entries []*Entry
stop chan struct{}
add chan *Entry
snapshot chan []*Entry
running bool
5.2 Entry调度实体
type Entry struct {
Schedule Schedule
Next time.Time
Prev time.Time
Job Job
5.3 Job
Job：每一个实体包含一个需要运行的Job,这是一个接口，只有一个方法：Run
type Job interface {
Run()
由于 Entity 中需要 Job 类型，因此，我们希望定期运行的任务，就需要实现 Job 接口。同时，由于 Job 接口只有一个无参数无返回值的方法，为了使用方便，作者提供了一个类型
type FuncJob func()
它通过简单的实现 Run() 方法来实现 Job 接口：
func (f FuncJob) Run() { f() }
这样，任何无参数无返回值的函数，通过强制类型转换为 FuncJob，就可以当作 Job 来使用了，AddFunc 方法 就是这么做的。
5.4 Schedule
每个实体包含一个调度器（Schedule）负责调度 Job 的执行。它也是一个接口。Schedule 的具体实现通过解析 Cron 表达式得到。库中提供了 Schedule 的两个具体实现，分别是 SpecSchedule 和 ConstantDelaySchedule。
type Schedule interface {
Next(time.Time) time.Time
5.4.1 SpecSchedule
从开始介绍的 Cron 表达式可以容易得知各个字段的意思，同时，对各种表达式的解析也会最终得到一个 SpecSchedule 的实例。库中的 Parse 返回的其实就是 SpecSchedule 的实例（当然也就实现了 Schedule 接口）
type SpecSchedule struct {
Second, Minute, Hour, Dom, Month, Dow uint64
5.4.2 ConstantDelaySchedule
type ConstantDelaySchedule struct {
Delay time.Duration
这是一个简单的循环调度器，如：每 5 分钟。注意，最小单位是秒，不能比秒还小，比如 毫秒。
通过 Every 函数可以获取该类型的实例，如下得到的是一个每 5 秒执行一次的调度器。：
constDelaySchedule := Every(5e9)
6 函数调用
6.1 实例化 Cron
实例化时，成员使用的基本是默认值；
func New() *Cron {
return &Cron{
entries: nil,
add: make(chan *Entry),
stop: make(chan struct{}),
snapshot: make(chan []*Entry),
running: false,
6.2 成员方法
如果对每个方法调用还是不了解可以去看一下每个函数的实现源码
type EntryID int
func (c *Cron) AddFunc(spec string, cmd func()) (EntryID, error)
func (c *Cron) AddJob(spec string, cmd Job) (EntryID, error)
func (c *Cron) Entries() []*Entry
func (c *Cron) Location() *time.Location
func (c *Cron) Entry(id EntryID) Entry
func (c *Cron) Remove(id EntryID)
func (c *Cron) Schedule(schedule Schedule, cmd Job) EntryID
func (c *Cron) Start()
func (c *Cron) Stop()
func (c *Cron) Run()
7 更多参考资料
定时器API
