Deprecated: imwpcache\f884414bce24ee67f\f73723ec7b1919fa5::__construct(): Implicitly marking parameter $YECBGYFECGEAFWHA as nullable is deprecated, the explicit nullable type must be used instead in /www/wwwroot/www.chuangxiangniao.com/wp-content/plugins/imwpcache-dist/build/f884414bce24ee67ff73723ec7b1919fa5.php on line 2

Deprecated: imwpcache\f884414bce24ee67f\f73723ec7b1919fa5::__construct(): Implicitly marking parameter $BBWFDDBHHYHDXXAB as nullable is deprecated, the explicit nullable type must be used instead in /www/wwwroot/www.chuangxiangniao.com/wp-content/plugins/imwpcache-dist/build/f884414bce24ee67ff73723ec7b1919fa5.php on line 2
Golang如何开发基础的定时任务_Golang定时任务项目实战_创想鸟

Golang如何开发基础的定时任务_Golang定时任务项目实战

使用time.Ticker可实现每5秒执行一次日志清理的周期性任务,通过监听其C channel触发逻辑并用defer stop避免泄漏。

golang如何开发基础的定时任务_golang定时任务项目实战

在Go语言开发中,定时任务是常见的需求,比如每天凌晨统计报表、每隔几分钟同步数据等。Golang本身提供了简洁高效的机制来实现定时任务,不需要依赖第三方框架也能轻松完成。

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

Go的 time.Ticker 可以按固定时间间隔触发任务,适合执行周期性的操作。

例如,每5秒执行一次日志清理:

创建一个 ticker,设置时间间隔用 for 循环监听其 C channel收到信号后执行具体逻辑程序退出时记得 stop ticker 防止资源泄露

代码示例:

立即学习“go语言免费学习笔记(深入)”;

package main

import ("fmt""time")

func main() {ticker := time.NewTicker(5 * time.Second)defer ticker.Stop()

for range ticker.C {    fmt.Println("执行定时清理任务:", time.Now())    // 这里写具体的业务逻辑}

}

使用 time.Timer 实现单次延迟任务

如果只需要延迟执行一次,比如10秒后发送提醒,用 time.Timer 更合适。

它只会触发一次,之后需要重新创建。

示例:10秒后发送通知

timer := time.NewTimer(10 * time.Second)<-timer.Cfmt.Println("10秒已到,发送提醒")

也可以通过 Reset 方法重复使用 Timer,但要注意并发安全。

模拟 Cron 行为:每天固定时间运行

有些任务需要在每天某个时间点运行,比如凌晨2点备份数据。这种场景可以用循环加时间计算来实现。

思路是:

计算今天目标时间(如 02:00:00)如果已过,则加24小时作为下次触发时间用 time.Until 得出等待时长用 Timer 等待并执行执行完继续下一轮

代码片段:

func runDailyAt(hour, min, sec int, task func()) {    for {        now := time.Now()        next := time.Date(now.Year(), now.Month(), now.Day(), hour, min, sec, 0, now.Location())
    if next.Before(now) {        next = next.Add(24 * time.Hour)    }    timer := time.NewTimer(time.Until(next))    <-timer.C    task()}

}

// 使用go runDailyAt(2, 0, 0, func() {fmt.Println("开始执行每日备份")})

控制并发与错误处理

实际项目中要避免任务重叠执行。比如前一次还没结束,下一次又开始了。

可以加锁或使用布尔标志位防止并发:

var running boolvar mu sync.Mutex

func safeTask() {mu.Lock()if running {mu.Unlock()return}running = truemu.Unlock()

// 执行任务fmt.Println("任务开始")time.Sleep(3 * time.Second) // 模拟耗时fmt.Println("任务结束")mu.Lock()running = falsemu.Unlock()

}

同时建议把任务包裹在 defer recover 中,防止 panic 导致整个程序退出。

基本上就这些。Golang的定时任务并不复杂,关键是根据场景选择 Ticker、Timer 或手动计算时间。合理管理资源和异常,就能稳定运行在生产环境。

以上就是Golang如何开发基础的定时任务_Golang定时任务项目实战的详细内容,更多请关注创想鸟其它相关文章!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1421827.html

赞 (0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
Go Goroutine数据定时输出:共享状态与互斥锁实践
上一篇 2025年12月16日 16:19:37
深入理解Go HTTP服务器对畸形请求的处理限制
下一篇 2025年12月16日 16:19:49

相关推荐

发表回复

登录后才能评论
关注微信