Golang AGScheduler动态持久化任务调度的强大库使用实例

更新时间：2023年10月16日 11:09:35 作者：kwkwc

这篇文章主要为大家介绍了Golang AGScheduler动态持久化任务调度的强大库使用实例详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪

正文

以前一直使用 Python 的任务调度库 APScheduler（支持任务持久化，支持多种存储方式），但由于没有找到与它功能和使用方式类似的 Golang 库，所以模仿 APScheduler 3.x 写了个简易版本的 AGScheduler。

AGScheduler

Advanced Golang Scheduler (AGScheduler) 是一款适用于 Golang 的任务调度程序，支持多种调度方式，动态更改和持久化任务

警示

该库处于实验阶段，不建议用于生产环境

链接 https://github.com/kwkwc/agscheduler

特性

支持三种调度方式
- [x] 一次性执行
- [x] 间隔执行
- [x] Cron 式调度
支持多种任务存储方式
- [x] Memory
- [x] GROM(任何 GROM 支持的 RDBMS 都能运行)
- [x] Redis
- [x] MongoDB

使用

package main
import (
    "fmt"
    "log/slog"
    "time"
    "github.com/kwkwc/agscheduler"
    "github.com/kwkwc/agscheduler/stores"
)
func printMsg(j agscheduler.Job) {
    slog.Info(fmt.Sprintf("Run %s %s\n", j.Name, j.Args))
}
func main() {
    agscheduler.RegisterFuncs(printMsg)
    store := &stores.MemoryStore{}
    scheduler := &agscheduler.Scheduler{}
    scheduler.SetStore(store)
    job := agscheduler.Job{
        Name:     "Job",
        Type:     agscheduler.TYPE_INTERVAL,
        Timezone: "UTC",
        Func:     printMsg,
        Args:     []any{"arg1", "arg2", "arg3"},
        Interval: 2 * time.Second,
    }
    jobId := scheduler.AddJob(job)
    job, _ = scheduler.GetJob(jobId)
    slog.Info(fmt.Sprintf("Scheduler add %s %s.\n\n", job.Name, job))
    scheduler.Start()
    slog.Info("Scheduler Start.\n\n")
    select {}
}

注册函数

由于 golang 无法序列化函数，所以 scheduler.Start() 之前需要使用 RegisterFuncs 注册函数

完整示例

致谢

APScheduler

以上就是Golang AGScheduler动态持久化任务调度的强大库使用实例的详细内容，更多关于Go AGScheduler任务调度的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:

go语言中strings包的用法汇总
Golang语言 strings标准库包主要涉及字符串的基本操作，下面我们来详细分析下吧
2018-10-10
Go语言七篇入门教程七GC垃圾回收三色标记
这篇文章主要为大家介绍了Go语言教程关于GC垃圾回收三色标记的示例详解，本篇文章是Go语言七篇入门教程系列文章，有需要的朋友可以借鉴参考下，希望能够有所帮助
2021-11-11
Go语言中make和new函数的用法与区别
这篇文章介绍了Go语言中make和new函数的用法与区别，文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2022-07-07
Go映射的使用
Go提供了另一个重要的数据类型,称为map,它将唯一键映射到值,本文主要介绍了Go映射的使用,包括声明映射、初始化映射、操作映射等,感兴趣的可以了解一下
2023-11-11
Golang实现CronJob(定时任务)的方法详解
这篇文章主要为大家详细介绍了Golang如何通过一个单 pod 去实现一个常驻服务，去跑定时任务（CronJob），文中的示例代码讲解详细，需要的可以参考下
2023-04-04
图解Golang的GC垃圾回收算法
这篇文章主要介绍了图解Golang的GC垃圾回收算法，详细的介绍了三种经典的算法，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2019-03-03
go语言实现字符串base64编码的方法
这篇文章主要介绍了go语言实现字符串base64编码的方法,实例分析了Go语言操作字符串的技巧及base64编码的使用技巧,需要的朋友可以参考下
2015-03-03
GScript 编写标准库示例详解
这篇文章主要为大家介绍了GScript 编写标准库示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2022-10-10
详解如何利用GORM实现MySQL事务
为了确保数据一致性，在项目中会经常用到事务处理，对于MySQL事务相信大家应该都不陌生。这篇文章主要总结一下在Go语言中Gorm是如何实现事务的；感兴趣的小伙伴们可以参考借鉴，希望对大家能有所帮助
2022-09-09
Go语言原子操作及互斥锁的区别
原子操作就是不可中断的操作，本文主要介绍了Go语言原子操作及互斥锁的区别，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2021-12-12