背景:
在Java中定时任务有成熟的框架 如quartz等 用起来比较方便 到了go 相对要少一些 特别是一些复杂的定时任务,比如:
要求: 1、在指定时间开始执行任务 2、按照指定周期(单位:minutes)重复执行 3、执行固定的次数或者到截止时间结束任务 4、任务支持取消 包含未执行或者正在执行的任务
代码样例:
type Task struct {
BeginTime time.Time // 任务开始时间
EndTime time.Time // 任务结束时间
TaskID string
Count int // 执行次数
Interval int64 // 执行间隔
}
func createTimer(task *Task, stopChanel chan Task) {
ctx, cancel := context.WithCancel(context.Background())
defer cancel()
select {
case <-time.After(time.Since(task.BeginTime)):
go doJob(task, ctx)
case <-stopChanel: // 如果任务未开始 则从这里退出
fmt.Println("任务还未开始 提前收到结束信号 结束任务")
return
}
// 如果任务已经启动 此处监听停止任务信号
<-stopChanel
fmt.Println("任务启动了 但是收到结束信号 等到当前执行任务结束 子协程即将退出")
}
func doJob(task *Task, ctx context.Context) {
count := 0
for {
select {
case <-ctx.Done():
fmt.Println("收到父协程结束信号,任务提前结束")
goto loopend
default:
doJobDetail(task)
count++
if count == task.Count {
goto loopend
}
if time.Now().UTC().After(task.EndTime) {
goto loopend
}
// 等待一个周期
t := time.NewTicker(time.Minute * time.Duration(task.Interval))
<-t.C
}
}
loopend:
fmt.Println("执行任务结束")
// 这里省略了一个全局维护的广播站 用来告知该任务已经结束 否则父携程的停止channel会一直阻塞导致内存泄漏
}
func doJobDetail(task *Task) {
fmt.Printf("执行任务%s。。。", task.TaskID)
}