如何设置定期启动 cron 作业并指定起始时间

亲爱的编程学习爱好者，如果你点开了这篇文章，说明你对《如何设置定期启动 cron 作业并指定起始时间》很感兴趣。本篇文章就来给大家详细解析一下，主要介绍一下，希望所有认真读完的童鞋们，都有实质性的提高。

我想构建一个程序，它运行许多 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 秒后立即发生。

但是，由于 starttimes 是程序启动前 4 秒和 3 秒，因此我希望事件分别在程序启动后 6 秒和 7 秒发生（以及之后每 10 秒发生一次）。

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

解决方案

这看起来只是简单的数学：

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

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

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)
        }
    }
}

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于Golang的相关知识，也可关注golang学习网公众号。