格式類型
字段組成（從左到右）
精度
適用場景
標(biāo)準(zhǔn)格式（兼容Unix）
分（0-59）、時(shí)（0-23）、日（1-31）、月（1-12）、周（0-6，0為周日）
分鐘級
無需秒級精度的定時(shí)任務(wù)
擴(kuò)展格式（robfig擴(kuò)展）
秒（0-59）、分（0-59）、時(shí)（0-23）、日（1-31）、月（1-12）、周（0-6）
秒級
需要高精度定時(shí)的任務(wù)（如每5秒執(zhí)行一次）

表達(dá)式
格式類型
執(zhí)行頻率
`*/5 * * * *`
標(biāo)準(zhǔn)格式
每5分鐘執(zhí)行一次
`0 0 3 * * *`
擴(kuò)展格式
每天凌晨3點(diǎn)0分0秒執(zhí)行
`0 30 8 * * 1-5`
標(biāo)準(zhǔn)格式
工作日（周一到周五）早上8點(diǎn)30分執(zhí)行
`@every 10s`
快捷指令
每10秒執(zhí)行一次
`@daily`
快捷指令
每天凌晨0點(diǎn)執(zhí)行（等價(jià)于`0 0 0 * * *`）
`@weekly`
快捷指令
每周日凌晨0點(diǎn)執(zhí)行
?? 注意：快捷指令`@every <duration>`中的時(shí)長需符合Golang`time.Duration`格式（如`s`秒、`m`分、`h`時(shí)）。

package main

import (
  "fmt"
  "time"

  "github.com/robfig/cron/v3"
)

// 定義要執(zhí)行的任務(wù)函數(shù)
func task() {
  fmt.Printf("Task executed at: %s\n", time.Now().Format("2006-01-02 15:04:05"))
}

func main() {
  // 1. 創(chuàng)建調(diào)度器（默認(rèn)使用本地時(shí)區(qū)，支持秒級精度）
  c := cron.New(cron.WithSeconds()) // 啟用秒級字段，若用標(biāo)準(zhǔn)格式可省略該參數(shù)

  // 2. 添加定時(shí)任務(wù)（表達(dá)式：每5秒執(zhí)行一次）
  // AddFunc參數(shù)：Cron表達(dá)式、任務(wù)函數(shù)（無參數(shù)、無返回值）
  _, err := c.AddFunc("*/5 * * * * *", task)
  if err != nil {
    fmt.Printf("Failed to add task: %v\n", err)
    return
  }

  // 3. 啟動調(diào)度器（非阻塞，會啟動一個(gè)新協(xié)程執(zhí)行任務(wù)）
  c.Start()
  fmt.Println("Cron scheduler started. Waiting for tasks...")

  // 阻塞主協(xié)程，避免程序退出（實(shí)際項(xiàng)目中可結(jié)合服務(wù)生命周期管理）
  select {}
}

func main() {
  // 加載時(shí)區(qū)（Asia/Shanghai對應(yīng)北京時(shí)間）
  loc, err := time.LoadLocation("Asia/Shanghai")
  if err != nil {
    fmt.Printf("Failed to load location: %v\n", err)
    return
  }
  // 創(chuàng)建指定時(shí)區(qū)的調(diào)度器（同時(shí)啟用秒級精度）
  c := cron.New(
    cron.WithSeconds(),
    cron.WithLocation(loc),
  )
  // 添加任務(wù)（按北京時(shí)間每天凌晨3點(diǎn)執(zhí)行）
  c.AddFunc("0 0 3 * * *", func() {
    fmt.Printf("Task executed at CST: %s\n", time.Now().Format("2006-01-02 15:04:05"))
  })
  c.Start()
  select {}
}

func main() {
  c := cron.New(cron.WithSeconds())
  // 添加任務(wù)并記錄ID
  taskID, _ := c.AddFunc("*/10 * * * * *", func() {
    fmt.Println("Dynamic task executed")
  })
  fmt.Printf("Added task with ID: %d\n", taskID)
  c.Start()
  // 30秒后移除任務(wù)
  time.AfterFunc(30*time.Second, func() {
    c.Remove(taskID)
    fmt.Printf("Task %d removed\n", taskID)
  })
  // 60秒后停止調(diào)度器
  time.AfterFunc(60*time.Second, func() {
    ctx := c.Stop()
    <-ctx.Done() // 等待當(dāng)前任務(wù)執(zhí)行完成
    fmt.Println("Cron scheduler stopped")
  })
  select {}
}

// 方式1：通過閉包傳遞參數(shù)
func main() {
  c := cron.New(cron.WithSeconds())
  // 帶參數(shù)的任務(wù)邏輯
  taskWithParam := func(name string) func() {
    return func() {
      fmt.Printf("Task %s executed at: %s\n", name, time.Now().Format("2006-01-02 15:04:05"))
    }
  }
  // 添加兩個(gè)不同參數(shù)的任務(wù)
  c.AddFunc("*/5 * * * * *", taskWithParam("TaskA"))
  c.AddFunc("*/8 * * * * *", taskWithParam("TaskB"))
  c.Start()
  select {}
}
// 方式2：通過結(jié)構(gòu)體實(shí)現(xiàn)（適用于復(fù)雜任務(wù)）
type Task struct {
  Name string
}
func (t *Task) Run() {
  fmt.Printf("Struct task %s executed at: %s\n", t.Name, time.Now().Format("2006-01-02 15:04:05"))
}
func main() {
  c := cron.New(cron.WithSeconds())
  // AddJob添加實(shí)現(xiàn)cron.Job接口的對象（需實(shí)現(xiàn)Run()方法）
  c.AddJob("*/5 * * * * *", &Task{Name: "StructTask"})
  c.Start()
  select {}
}

import (
  "fmt"
  "log"
  "time"

  "github.com/robfig/cron/v3"
)

// 帶錯(cuò)誤處理的任務(wù)
func taskWithError() {
  defer func() {
    if err := recover(); err != nil {
      log.Printf("Task panicked: %v\n", err)
    }
  }()

  // 模擬錯(cuò)誤
  fmt.Println("Executing task with error handling...")
  panic("something went wrong")
}

func main() {
  // 配置日志記錄（輸出調(diào)度器狀態(tài)、任務(wù)執(zhí)行情況）
  logger := cron.VerbosePrintfLogger(log.New(log.Writer(), "CRON: ", log.LstdFlags))
  c := cron.New(
    cron.WithSeconds(),
    cron.WithLogger(logger), // 啟用日志
  )

  c.AddFunc("*/10 * * * * *", taskWithError)
  c.Start()

  select {}
}

import (
  "fmt"
  "time"
  "github.com/robfig/cron/v3"
  "github.com/robfig/cron/v3/chain"
)
// 模擬耗時(shí)任務(wù)（執(zhí)行時(shí)間15秒）
func longRunningTask() {
  fmt.Printf("Long task started at: %s\n", time.Now().Format("2006-01-02 15:04:05"))
  time.Sleep(15 * time.Second)
  fmt.Printf("Long task finished at: %s\n", time.Now().Format("2006-01-02 15:04:05"))
}
func main() {
  // 配置中間件：若任務(wù)仍在運(yùn)行，跳過本次執(zhí)行
  jobWrapper := chain.SkipIfStillRunning(cron.DefaultLogger)
  c := cron.New(
    cron.WithSeconds(),
    cron.WithChain(jobWrapper), // 應(yīng)用中間件
  )
  // 每10秒執(zhí)行一次，但任務(wù)耗時(shí)15秒，會跳過并發(fā)執(zhí)行的次數(shù)
  c.AddFunc("*/10 * * * * *", longRunningTask)
  c.Start()
  select {}
}

package main
import (
  "fmt"
  "log"
  "sync"
  "time"
  "github.com/gin-gonic/gin"
  "github.com/robfig/cron/v3"
)
// 模擬緩存存儲
var (
  cache  = make(map[string]string)
  mu     sync.Mutex // 保證緩存操作并發(fā)安全
  expire = 5 * time.Minute // 緩存過期時(shí)間
)
// 清理過期緩存的任務(wù)
func cleanExpiredCache() {
  mu.Lock()
  defer mu.Unlock()
  now := time.Now()
  count := 0
  // 遍歷緩存，刪除過期數(shù)據(jù)（實(shí)際項(xiàng)目中可給緩存值添加過期時(shí)間字段）
  for key := range cache {
    // 模擬過期判斷（實(shí)際需存儲緩存創(chuàng)建時(shí)間）
    if now.Sub(time.UnixMilli(0)).Seconds()%300 > 200 {
      delete(cache, key)
      count++
    }
  }
  log.Printf("Cleaned %d expired cache entries at: %s\n", count, now.Format("2006-01-02 15:04:05"))
}
func main() {
  // 1. 初始化定時(shí)器，每5分鐘清理一次緩存
  c := cron.New(cron.WithSeconds())
  c.AddFunc("0 0 */5 * * *", cleanExpiredCache)
  c.Start()
  defer func() {
    ctx := c.Stop()
    <-ctx.Done()
    log.Println("Cron scheduler stopped")
  }()
  // 2. 初始化Gin
  r := gin.Default()
  // 模擬設(shè)置緩存接口
  r.GET("/set-cache", func(c *gin.Context) {
    key := c.Query("key")
    val := c.Query("val")
    if key == "" || val == "" {
      c.JSON(400, gin.H{"error": "key and val are required"})
      return
    }
    mu.Lock()
    cache[key] = val
    mu.Unlock()
    c.JSON(200, gin.H{"msg": "cache set successfully"})
  })
  // 3. 啟動Gin服務(wù)
  log.Println("Gin server started on :8080")
  if err := r.Run(":8080"); err != nil {
    log.Fatalf("Gin server failed to start: %v", err)
  }
}