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语言中使用 buffered channel 实现线程安全的 pool
这篇文章主要介绍了Go语言中使用 buffered channel 实现线程安全的 pool,因为Go语言自带的sync.Pool并不是很好用,所以自己实现了一线程安全的 pool,需要的朋友可以参考下
2014-10-10
golang中使用sync.Map的方法
这篇文章主要介绍了golang中使用sync.Map的方法，本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
2020-06-06
Go语言判断文件或文件夹是否存在的方法
这篇文章主要介绍了Go语言判断文件或文件夹是否存在的方法,结合具体实例形式对比分析了Go语言针对文件与目录判断的操作技巧与相关注意事项,需要的朋友可以参考下
2017-05-05
GoLang context包的使用方法介绍
日常Go开发中，Context包是用的最多的一个了，几乎所有函数的第一个参数都是ctx，那么我们为什么要传递Context呢，Context又有哪些用法，底层实现是如何呢？相信你也一定会有探索的欲望，那么就跟着本篇文章，一起来学习吧
2023-03-03
golang项目如何上线部署到Linu服务器(方法详解)
这篇文章主要介绍了golang项目如何上线部署到Linu服务器，本文通过两种方法给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
2020-10-10
详解Go module的介绍及使用
module是一个相关Go包的集合，它是源代码更替和版本控制的单元。这篇文章主要介绍了Go module的介绍及使用,需要的朋友可以参考下
2020-10-10
Golang Template实现自定义函数的操作指南
这篇文章主要为大家详细介绍了Golang如何利用Template实现自定义函数的操作,文中的示例代码简洁易懂,感兴趣的小伙伴可以跟随小编一起学习一下
2025-02-02
利用Go语言初步搭建一个web应用的教程
这篇文章主要介绍了利用Go语言初步搭建一个web应用的教程,由于很多国人盲目迷信谷歌,导致Go语言在国内的人气远超国外...需要的朋友可以参考下
2015-06-06
Go中的Timer 和 Ticker详解
在日常开发中,我们可能会遇到需要延迟执行或周期性地执行一些任务,这个时候就需要用到 Go 语言中的定时器,本文将会对这两种定时器类型进行介绍,感兴趣的朋友一起看看吧
2024-07-07
使用Go调用OpenAI兼容API模型
本文介绍了使用Go语言调用兼容OpenAI API的模型（LMStudio/Ollama）的方法,主要涵盖了非流式对话、流式打字机效果、多轮上下文对话以及图片交互等内容,文章详细解释了如何准备环境,实现非流式对话的特点,需要的朋友可以参考下
2026-05-05