Как начать работу cron через равные промежутки времени, начиная с прошлого - PullRequest
Новая
       25

Как начать работу cron через равные промежутки времени, начиная с прошлого

0 голосов
/ 25 марта 2020

Я хотел бы создать программу, которая запускает несколько заданий 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 s - за 4 и 3 секунды до запуска программы, я бы хотел, чтобы события происходили Через 6 и 7 секунд после запуска программы (и каждые 10 секунд после этого) соответственно.

Есть ли способ сделать это с помощью gocron или каким-либо другим инструментом?

Ответы [ 2 ]

1 голос
/ 25 марта 2020

Это похоже на простую математику: 

    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

1 голос
/ 25 марта 2020

Мы можем попытаться использовать простой тикер, это не полное решение, но должно быть достаточно простым для адаптации. 

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