使用go-co-op/gocron时goroutine持续增长及单例模式不生效问题

1. 同标签一次性任务未遵循单例模式的根因 #

gocron v2的WithSingletonMode(LimitModeReschedule)根本不是按标签来限制的——它只管单个Job实例自己的调度。你代码里每次循环都新建一个Job，哪怕标签一样，这些Job都是完全独立的个体，所以SingletonMode不会在它们之间生效。这个模式的作用是：如果某个Job是周期性的，当它还在执行时，它自己的下一次调度会被重新安排，而不是阻止其他同标签的Job启动。

2. Goroutine数量持续增长的可能原因 #

• Shutdown未等待任务执行完成：你当前使用的s.Shutdown()是默认参数，默认不会等正在执行的任务结束就关闭调度器，导致部分任务的goroutine未被正常回收，调度器内部的后台goroutine也可能残留。
• OneTimeJob执行后未被自动清理：gocron v2中，一次性任务执行完毕后如果未被调度器自动移除，每个Job对应的调度相关goroutine会持续占用资源，累积导致数量增长。
• 调度器残留后台goroutine：任务本身的goroutine会在time.Sleep结束后退出，但调度器为每个Job创建的后台调度goroutine如果未随任务完成销毁，也会导致总数居高不下。

解决办法 #

实现同标签任务互斥执行 #

自己基于标签实现互斥逻辑，比如用sync.Map存储每个标签的互斥锁：

import "sync"

var tagLocks = sync.Map{}

func getTagLock(tag string) *sync.Mutex {
    lock, _ := tagLocks.LoadOrStore(tag, &sync.Mutex{})
    return lock.(*sync.Mutex)
}

// 创建任务时添加标签互斥逻辑
_, _ = s.NewJob(
    gocron.OneTimeJob(gocron.OneTimeJobStartImmediately()),
    gocron.NewTask(
        func() {
            tag := fmt.Sprintf("tag-%d", i%2)
            lock := getTagLock(tag)
            lock.Lock()
            defer lock.Unlock()

            t.Logf("One time job [%d] started @ [%v] with [%d] goroutines", i, time.Now(), runtime.NumGoroutine())
            time.Sleep(5 * time.Second)
            t.Logf("One time job [%d] finished @ [%v] with [%d] goroutines", i, time.Now(), runtime.NumGoroutine())
        },
    ),
    gocron.WithTags(fmt.Sprintf("tag-%d", i%2)),
)

解决Goroutine增长问题 #

1. 修改Shutdown逻辑，等待任务完成：
   调整defer中的Shutdown调用，添加等待参数确保所有任务执行完毕后再关闭调度器：

   defer func() {
       // 等待所有任务执行完成后关闭调度器
       _ = s.Shutdown(gocron.WithShutdownWaitForJobs())
   }()
   

2. 手动移除已完成的OneTimeJob：
   创建Job时保存返回的JobID，在任务执行完毕后调用RemoveJob清理实例：

   jobID, _ := s.NewJob(
       gocron.OneTimeJob(gocron.OneTimeJobStartImmediately()),
       gocron.NewTask(
           func() {
               // ...任务执行逻辑...
               s.RemoveJob(jobID)
           },
       ),
       gocron.WithTags(fmt.Sprintf("tag-%d", i%2)),
   )
   

3. 延迟检查goroutine数量：
   所有任务执行完成后，等待几秒再检查goroutine数量，确认调度器的后台goroutine已正常退出。

额外提醒 #

你的场景是周期性生成带不同标签的一次性任务，建议将标签互斥逻辑封装为通用的任务包装函数，避免重复代码；同时定期清理已完成的Job实例，防止调度器资源累积。

内容的提问来源于stack exchange，提问作者mmind