網站首頁 編程語言 正文
Golang cron 定時器和定時任務
Golang中time包有兩個定時器,分別為 ticker 和 timer。兩者都可以實現定時功能,但各自都有自己的使用場景。
timer和ticker的區別
- ticker定時器表示每隔一段時間就執行一次,一般可執行多次。
- timer定時器表示在一段時間后執行,默認情況下只執行一次,如果想再次執行的話,每次都需要調用 time.Reset() 方法,此時效果類似ticker定時器。同時也可以調用 Stop() 方法取消定時器
- timer定時器比ticker定時器多一個 Reset() 方法,兩者都有 Stop() 方法,表示停止定時器,底層都調用了stopTimer() 函數。
Timer
Timer是一個定時器。代表未來的一個單一事件,你可以告訴timer你要等待多長時間。
package main import ( "fmt" "time" ) func main() { //設置定時器為3秒 timer := time.NewTimer(3 * time.Second) fmt.Println("當前時間為:", time.Now()) t := <-timer.C //從定時器拿數據 fmt.Println("當前時間為:", t) }
Ticker
Ticker是一個周期觸發定時的計時器,它會按照一個時間間隔往channel發送系統當前時間,而channel的接收者可以以固定的時間間隔從channel中讀取事件。
Ticker是一個定時觸發的計時器,
它會以一個間隔(interval)往channel發送一個事件(當前時間),
而channel的接收者可以以固定的時間間隔從channel中讀取事件。
package main import ( "fmt" "time" ) func main() { //創建一個周期性的定時器 ticker := time.NewTicker(3 * time.Second) fmt.Println("當前時間為:", time.Now()) go func() { for { //從定時器中獲取數據 t := <-ticker.C fmt.Println("當前時間為:", t) } }() for { time.Sleep(time.Second * 1) } }
cron 定時任務
package main import ( "github.com/robfig/cron" "log" "time" ) func main() { //cron1() //cron2() cron3() select { } } func cron1() { log.Println("Starting...") c := cron.New() c.AddFunc("* * * * * *", func() { log.Println("Run models.CleanAllTag...") }) c.AddFunc("* * * * * *", func() { log.Println("Run models.CleanAllArticle...") }) c.Start() t1 := time.NewTimer(time.Second * 10) for { select { case <-t1.C: t1.Reset(time.Second * 10) } } } func cron2() { log.Println("Starting...") c := cron.New() // 新建一個定時任務對象 c.AddFunc("* * * * * *", func() { log.Println("hello world") }) // 給對象增加定時任務 c.Start() //select { //} time.Sleep(10 * time.Second) c.Stop() } func cron3() { log.Println("Starting...") c := cron.New() h := Hello{"I Love You!"} // 添加定時任務 c.AddJob("*/2 * * * * *", h) // 添加定時任務 5秒執行一次 c.AddFunc("*/5 * * * * *", func() { log.Println("hello word") }) s, err := cron.Parse("*/3 * * * * *") if err != nil { log.Println("Parse error") } h2 := Hello{"I Hate You!"} c.Schedule(s, h2) // 其中任務 c.Start() // 關閉任務 defer c.Stop() } type Hello struct { Str string } func(h Hello) Run() { log.Println(h.Str) }
參考鏈接:
https://blog.haohtml.com/archives/19859
https://studygolang.com/articles/17624
https://www.jianshu.com/p/fd3dda663953
https://blog.51cto.com/u_13914991/2294357
https://www.cnblogs.com/yinzhengjie/p/12244385.html
http://t.zoukankan.com/yinzhengjie-p-12245289.html
https://blog.51cto.com/u_13914991/2294357
原文鏈接:https://blog.csdn.net/yinjl123456/article/details/127115171
相關推薦
- 2022-04-11 一文帶你了解什么是瀏覽器緩存,DNS,CDN及域名解析類型_網站運營
- 2022-04-23 R語言繪制line?plot線圖示例詳解_R語言
- 2022-09-14 C語言多媒體框架GStreamer入門和概述_C 語言
- 2022-09-09 python?對excel交互工具的使用詳情_python
- 2022-02-14 Uncaught TypeError: Failed to execute ‘appendChild
- 2021-12-03 Android識別NFC芯片制造商的方法_Android
- 2021-11-08 Linux常用硬盤管理相關命令介紹_Linux
- 2022-06-22 Android使用EventBus多次接收消息_Android
- 最近更新
-
- window11 系統安裝 yarn
- 超詳細win安裝深度學習環境2025年最新版(
- Linux 中運行的top命令 怎么退出?
- MySQL 中decimal 的用法? 存儲小
- get 、set 、toString 方法的使
- @Resource和 @Autowired注解
- Java基礎操作-- 運算符,流程控制 Flo
- 1. Int 和Integer 的區別,Jav
- spring @retryable不生效的一種
- Spring Security之認證信息的處理
- Spring Security之認證過濾器
- Spring Security概述快速入門
- Spring Security之配置體系
- 【SpringBoot】SpringCache
- Spring Security之基于方法配置權
- redisson分布式鎖中waittime的設
- maven:解決release錯誤:Artif
- restTemplate使用總結
- Spring Security之安全異常處理
- MybatisPlus優雅實現加密?
- Spring ioc容器與Bean的生命周期。
- 【探索SpringCloud】服務發現-Nac
- Spring Security之基于HttpR
- Redis 底層數據結構-簡單動態字符串(SD
- arthas操作spring被代理目標對象命令
- Spring中的單例模式應用詳解
- 聊聊消息隊列,發送消息的4種方式
- bootspring第三方資源配置管理
- GIT同步修改后的遠程分支