如何从过去的某个时间开始定期启动 cron 作业

Question

我想构建一个程序，其中运行有许多 cron 作业，这些作业通常在过去的时间启动。这是一个使用 gocron:

的简化示例

package main

import (
    "time"

    "github.com/jasonlvhit/gocron"
    "github.com/sirupsen/logrus"
)

// This slice would be obtained from persistent storage
var startTimes = []time.Time{
    time.Now().Add(-4 * time.Second),
    time.Now().Add(-3 * time.Second),
}

func format(t time.Time) string {
    return t.Format("15:04:05")
}

func notify(startTime time.Time) {
    logrus.WithField("time", format(time.Now())).Infof("I started at %s\n", format(startTime))
}

func main() {
    for _, startTime := range startTimes {
        gocron.Every(10).Seconds().From(&startTime).Do(notify, startTime)
    }

    logrus.Infof("Starting at %s...\n", format(time.Now()))
    <-gocron.Start()
}

如果我运行这个，我得到以下输出：

INFO[0000] Starting at 00:30:54...                      
INFO[0010] I started at 00:30:50                         fields.time="00:31:04"
INFO[0010] I started at 00:30:51                         fields.time="00:31:04"

我观察到所有事件都在我启动程序 10 秒后同时发生。

但是，由于 startTime 是程序开始前的 4 秒和 3 秒，我希望事件在程序开始后 6 秒和 7 秒发生（之后每 10 秒发生一次） ), 分别。

有没有办法用 gocron 或其他工具做到这一点？

Answer 1

我们可以尝试利用一个简单的代码，它不是一个完整的解决方案，但应该很容易适应。

package main

import (
    "fmt"
    "time"
)

func ticker(period time.Duration, length ...time.Duration) <-chan time.Time {
    ticker := time.NewTicker(period)

    if len(length) > 0 {
        done := make(chan bool)
        go func() {
            time.Sleep(period + length[0])
            done <- true
        }()

        go func() {
            <-done
            ticker.Stop()
        }()
    }

    return ticker.C

}

func main() {
    t1 := ticker(6*time.Second, 4*time.Second)
    t2 := ticker(7*time.Second, 3*time.Second)
    t3 := ticker(10 * time.Second)
    for {
        select {
        case t1 := <-t1:
            fmt.Println("t1: ", t1)
        case t2 := <-t2:
            fmt.Println("t2: ", t2)
        case t3 := <-t3:
            fmt.Println("t3: ", t3)
        }
    }
}

Answer 2

这似乎只是简单的数学运算：

    interval := 10 * time.Second
    nextTime := time.Now().Add((time.Since(startTime) + interval) % interval)
    gocron.Every(10).Seconds().From(&nextTime).Do(notify, nextTime)

https://play.golang.org/p/pwEZqy_LUuk

如何从过去的某个时间开始定期启动 cron 作业

How to start a cron job at regular intervals starting from a time in the past

go

cron-task