详解Go语言中如何创建Cron定时任务

go get github.com/robfig/cron/v3

package main

import (
	"fmt"
	"github.com/robfig/cron/v3"
	"time"
)

func main() {
	// 创建一个新的Cron实例，默认是支持分钟级别的调度，加上cron.WithSeconds() 支持秒级别调度
	c := cron.New(cron.WithSeconds()) //精确到秒级

	// 添加一个每5秒钟执行一次的定时任务
	spec := "*/5 * * * * *"
	// func (c *Cron) AddFunc(spec string, cmd func()) (EntryID, error)
	// AddFunc第一个参数是一个Cron表达式，表示任务的执行时间和频率；第二个参数是一个无参的函数
	c.AddFunc(spec, func() {
		fmt.Println("Task executed every 5 seconds", time.Now())
	})

	// 启动Cron实例，开始执行定时任务
	c.Start()

	// 为了演示效果，让主程序运行一段时间
	time.Sleep(30 * time.Second)

	// 停止Cron实例（在实际应用中，通常不需要手动停止Cron实例，除非程序需要退出）
	c.Stop()
}

package main

import (
	"fmt"
	"github.com/robfig/cron/v3"
	"time"
)

// MyJob 定义一个自定义的Job类型
type MyJob struct {
	// 可以根据需要添加其他字段
}

// Run 实现cron.Job接口中的Run方法
func (j *MyJob) Run() {
	fmt.Println("MyJob is running", time.Now())
}

func main() {
	c := cron.New(cron.WithSeconds())

	// 创建一个自定义Job的实例
	myJob := &MyJob{}

	// 添加自定义Job到Cron实例中。这里使用AddJob方法
	_, err := c.AddJob("*/5 * * * * *", myJob)
	if err != nil {
		fmt.Println("Error adding job:", err)
		return
	}

	c.Start()
	time.Sleep(30 * time.Second)
	c.Stop()
}

package main

import (
	"fmt"
	"github.com/robfig/cron/v3"
	"time"
)

func main() {
	c := cron.New(cron.WithSeconds())

	// 添加一个每5秒钟执行一次的定时任务
	entryID, err := c.AddFunc("*/5 * * * * *", func() {
		fmt.Println("Task 1: Every 5 seconds", time.Now())
	})
	if err != nil {
		fmt.Println("Error adding task 1:", err)
		return
	}
	// 启动定时器
	c.Start()
	// 等待一段时间，以便观察任务1的执行
	time.Sleep(10 * time.Second)

	// 删除任务1
	c.Remove(entryID)

	// 添加一个每10秒钟执行一次的定时任务
	_, err = c.AddFunc("*/10 * * * * *", func() {
		fmt.Println("Task 2: Every 10 seconds", time.Now())
	})
	if err != nil {
		fmt.Println("Error adding task 2:", err)
		return
	}

	// 为了演示效果，让主程序运行一段时间
	time.Sleep(30 * time.Second)

	c.Stop()
}

package main

import (
	"fmt"
	"github.com/robfig/cron/v3"
	"time"
)

func main() {
	// 创建一个新的Cron实例，默认是支持分钟级别的调度，加上cron.WithSeconds() 支持秒级别调度
	c := cron.New(cron.WithSeconds()) //精确到秒级

	// 添加一个每3秒钟执行一次的定时任务 也可以使用预定义时间格式
	spec := "@every 3s"
	// func (c *Cron) AddFunc(spec string, cmd func()) (EntryID, error)
	// AddFunc第一个参数是一个Cron表达式，表示任务的执行时间和频率；第二个参数是一个无参的函数
	c.AddFunc(spec, func() {
		fmt.Println("Task executed every 3 seconds", time.Now())
	})

	// 启动Cron实例，开始执行定时任务
	c.Start()

	// 为了演示效果，让主程序运行一段时间
	time.Sleep(30 * time.Second)

	// 停止Cron实例（在实际应用中，通常不需要手动停止Cron实例，除非程序需要退出）
	c.Stop()
}

package main

import (
	"fmt"
	"github.com/robfig/cron/v3"
)

func main() {
	c := cron.New(cron.WithSeconds())

	// 定义一个带参数的外部函数 外函数带有参数，返回一个函数
	executeTask := func(param string) func() {
		return func() {
			fmt.Println("Task executed with parameter:", param)
		}
	}

	// 使用闭包传递参数
	taskParam := "Hello, Cron with Closure!"
	c.AddFunc("@every 1s", executeTask(taskParam))

	c.Start()
	// 为了让程序运行足够长的时间以观察定时任务的执行，我们使用一个空的select语句来阻塞主goroutine
	select {}
}

package main

import (
	"fmt"
	"github.com/robfig/cron/v3"
	"time"
)

// ParamJob 定义带参数的Job类型
type ParamJob struct {
	param string
}

// Run 实现cron.Job接口的Run方法
func (j *ParamJob) Run() {
	fmt.Println("ParamJob executed with parameter:", j.param, time.Now())
}

func main() {
	c := cron.New(cron.WithSeconds())

	// 创建一个ParamJob实例并设置参数
	jobParam := "Hello, Cron with ParamJob!"
	//注意，这里定义对象的时候使用指针
	paramJob := &ParamJob{param: jobParam}

	// 将ParamJob实例添加到Cron实例中
	// 注意：由于AddJob方法期望的是一个cron.Job接口，因此我们需要将ParamJob实例的指针转换为cron.Job接口
	c.AddJob("@every 2s", paramJob)

	c.Start()
	// 使用一个空的select语句来阻塞主goroutine
	select {}
}