Golang定时任务调度功能实现示例-Golang-PHP中文网

Golang定时任务调度功能实现示例

P粉602998670

发布： 2025-09-29 17:24:04

原创

161人浏览过

Go语言中实现定时任务主要有三种方式：1. 使用time.Ticker实现周期性任务，如每5秒执行一次；2. 使用time.AfterFunc实现一次性延迟任务；3. 使用robfig/cron库支持复杂调度规则，如每天8点执行。此外，可通过sync.Mutex防止任务重入，避免并发执行问题。

golang定时任务调度功能实现示例

在Go语言中实现定时任务调度功能，有多种方式可以选择。最常见的是使用标准库 time.Timer 和 time.Ticker，以及第三方库如 robfig/cron 来实现更复杂的调度规则。下面通过几个典型示例展示如何在Golang中实现定时任务。

1. 使用 time.Ticker 实现周期性任务

适用于每隔固定时间执行一次的任务，比如每5秒打印一条日志。

package main
<p>import (
"fmt"
"time"
)</p><p>func main() {
ticker := time.NewTicker(5 * time.Second)
defer ticker.Stop()</p><pre class='brush:php;toolbar:false;'>for {
    select {
    case <-ticker.C:
        fmt.Println("执行定时任务：", time.Now())
    }
}

登录后复制

}

说明： time.NewTicker 创建一个周期性触发的 Ticker，通过监听其通道 ticker.C 可以在每次到达间隔时执行任务。记得调用 Stop() 防止资源泄漏。

立即学习“go语言免费学习笔记（深入）”；

2. 使用 time.AfterFunc 实现延迟执行

适用于只执行一次的延时任务，例如3秒后发送通知。

package main
<p>import (
"fmt"
"time"
)</p><p>func main() {
timer := time.AfterFunc(3*time.Second, func() {
fmt.Println("延迟任务执行：", time.Now())
})</p><pre class='brush:php;toolbar:false;'>// 阻塞主线程，确保程序不会提前退出
time.Sleep(5 * time.Second)
timer.Stop() // 如果需要可以取消

登录后复制

}

说明： AfterFunc 在指定时间后自动调用函数。适合一次性任务，也可以结合循环实现重复调度。

Superflow Rewrite

AI辅助高效网站设计、协作、注释工具，迭代和发布网站的最快方式

查看详情

3. 使用 cron 库实现复杂调度（如每天凌晨执行）

安装 robfig/cron：

go get github.com/robfig/cron/v3

登录后复制

示例代码：每天早上8点执行任务。

package main
<p>import (
"fmt"
"time"
"github.com/robfig/cron/v3"
)</p><p>func main() {
c := cron.New()</p><pre class='brush:php;toolbar:false;'>// 添加任务：每天 8:00 执行
c.AddFunc("0 8 * * *", func() {
    fmt.Println("每日任务执行：", time.Now())
})

c.Start()
defer c.Stop()

// 保持程序运行
select {}

登录后复制

}

说明： cron 表达式支持秒级（v3版本）或分钟级精度。常用格式为：
秒分时日月周。
例如："0 0 2 * * *" 表示每天凌晨2点执行"。

4. 控制并发与防止重入

某些任务耗时较长，需避免多个实例同时运行。可通过互斥锁控制。

package main
<p>import (
"fmt"
"sync"
"time"
"github.com/robfig/cron/v3"
)</p><p>func main() {
var mu sync.Mutex
isRunning := false</p><pre class='brush:php;toolbar:false;'>c := cron.New()
c.AddFunc("@every 10s", func() {
    mu.Lock()
    if isRunning {
        fmt.Println("任务正在执行，跳过本次调度")
        mu.Unlock()
        return
    }
    isRunning = true
    mu.Unlock()

    // 模拟耗时任务
    fmt.Println("任务开始：", time.Now())
    time.Sleep(15 * time.Second)
    fmt.Println("任务结束：", time.Now())

    mu.Lock()
    isRunning = false
    mu.Unlock()
})

c.Start()
defer c.Stop()

select {}

登录后复制

}

说明： 使用 sync.Mutex 和状态标志防止任务被重复触发，特别适用于执行时间可能超过调度周期的情况。

基本上就这些。根据实际需求选择合适的方式：简单周期用 Ticker，复杂时间表达式用 cron，注意控制并发和资源释放即可。

以上就是Golang定时任务调度功能实现示例的详细内容，更多请关注php中文网其它相关文章！