/tmp/x.log 每隔1-5分鐘執(zhí)行1次: 1-5 echo hello > /tmp/x.log 每天10點整、22點整..."/>
您好,登錄后才能下訂單哦!
cron格式:
分 時 日 月 周
每隔5分鐘執(zhí)行1次: /5 * echo hello > /tmp/x.log
每隔1-5分鐘執(zhí)行1次: 1-5 echo hello > /tmp/x.log
每天10點整、22點整執(zhí)行1次: 0 10,22 * echo hello > /tmp/x.log
每隔1-5分鐘執(zhí)行1次: 1-5 echo hello > /tmp/x.log
Parse():解析與校驗Cron表達式
Next():根據(jù)當前時間,計算下次調(diào)度時間
package main
import (
"fmt"
"github.com/gorhill/cronexpr"
"time"
)
func main() {
var (
expr *cronexpr.Expression
err error
now time.Time
nextTime time.Time
)
//每隔5分鐘執(zhí)行一次(這個庫支持7位,精確到秒、年)
if expr, err = cronexpr.Parse("*/5 * * * * * *"); err != nil {
fmt.Println(err)
return
}
//當前時間
now = time.Now()
//下次調(diào)度時間
nextTime = expr.Next(now)
//等待這個定時器超時
time.AfterFunc(nextTime.Sub(now), func() {
fmt.Println("被調(diào)度了:", nextTime)
}) //下次時間減去當前時間
time.Sleep(10 * time.Second)
}
調(diào)用一個cron
輸出:被調(diào)度了: 2019-04-19 17:00:30 +0800 CST
package main
import (
"fmt"
"github.com/gorhill/cronexpr"
"time"
)
//代表一個任務(wù)
type CronJob struct {
expr *cronexpr.Expression
nextTime time.Time //expr.Next(time.Now())就可以得到下一次調(diào)度時間
}
func main() {
//需要有1個調(diào)度協(xié)程,它定時檢查所有Cron任務(wù),誰過期了就執(zhí)行誰
var (
cronJob *CronJob
expr *cronexpr.Expression
now time.Time
scheduleTable map[string] *CronJob //key:任務(wù)名字,
)
scheduleTable = make(map[string]*CronJob)
//當前時間
now = time.Now()
//定義第一個cronjob
expr = cronexpr.MustParse("*/5 * * * * * *")
cronJob = &CronJob{
expr: expr,
nextTime: expr.Next(now),
}
//任務(wù)注冊到了調(diào)度表
scheduleTable["job1"] = cronJob
//定義第二個cronjob
expr = cronexpr.MustParse("*/5 * * * * * *")
cronJob = &CronJob{
expr: expr,
nextTime: expr.Next(now),
}
//任務(wù)注冊到了調(diào)度表
scheduleTable["job2"] = cronJob
//啟動調(diào)度協(xié)程
go func() {
var (
jobName string
cronJob *CronJob
now time.Time
)
//定時檢查任務(wù)調(diào)度表是否有到期的
for {
now = time.Now()
for jobName, cronJob = range scheduleTable {
//判斷是否過期(如果下次調(diào)度時間早于等于當前時間,說明已經(jīng)過期了)
if cronJob.nextTime.Before(now) || cronJob.nextTime.Equal(now) {
//啟動一個協(xié)程,執(zhí)行這個任務(wù)
go func(jobName string) {
fmt.Println("執(zhí)行:", jobName)
}(jobName)
//計算下一次調(diào)度時間
cronJob.nextTime = cronJob.expr.Next(now)
fmt.Println(jobName, "下次執(zhí)行時間:", cronJob.nextTime)
}
}
select {
//睡眠100毫秒(不讓它占用過多cpu)
case <- time.NewTimer(100 * time.Millisecond).C: //將在100毫秒可讀,返回
}
}
}()
time.Sleep(100 * time.Second)
}
調(diào)用多個cron,按時間間隔輸出:
執(zhí)行: job1
job1 下次執(zhí)行時間: 2019-04-19 17:31:20 +0800 CST
job2 下次執(zhí)行時間: 2019-04-19 17:31:20 +0800 CST
執(zhí)行: job2
執(zhí)行: job1
job1 下次執(zhí)行時間: 2019-04-19 17:31:25 +0800 CST
執(zhí)行: job2
job2 下次執(zhí)行時間: 2019-04-19 17:31:25 +0800 CST
執(zhí)行: job1
job1 下次執(zhí)行時間: 2019-04-19 17:31:30 +0800 CST
job2 下次執(zhí)行時間: 2019-04-19 17:31:30 +0800 CST
執(zhí)行: job2
......
免責聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進行舉報,并提供相關(guān)證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權(quán)內(nèi)容。