golang定时任务的一些尝试

golang定时任务的一些尝试

背景：

在Java中定时任务有成熟的框架 如quartz等 用起来比较方便  到了go 相对要少一些 特别是一些复杂的定时任务，比如：

要求：
1、在指定时间开始执行任务
2、按照指定周期（单位：minutes）重复执行
3、执行固定的次数或者到截止时间结束任务
4、任务支持取消 包含未执行或者正在执行的任务

代码样例：

package utils

import (
	"context"
	"fmt"
	"time"
)



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("收到父协程结束信号，任务提前结束")
			return
		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("执行任务结束")
	
	//。。。 这里省略了一个全局的广播站 用来通知正常结束的任务 否则父协程会一直阻塞 导致内存泄露
	// 伪代码  MS.multiChannel <- task

}

func doJobDetail(task *Task) {
	fmt.Printf("执行任务%s。。。", task.TaskID)

}