Я должен разослать тысячи напоминаний, чтобы избежать тикера каждую минуту? - PullRequest
Новая
       6

Я должен разослать тысячи напоминаний, чтобы избежать тикера каждую минуту?

0 голосов
/ 08 ноября 2018

У меня есть такая структура: 

type Notifications struct {
  Id int
  Start *time.Time
}

notifications := db.GetNotifications()

Так что теперь мне нужно отправлять эти уведомления всякий раз, когда время соответствует текущему времени. 

1  2018-11-07 09:05:00
2  2018-11-07 09:05:00
3  2018-11-07 09:15:00
..

Самый простой способ сделать это с помощью тикера: 

ticker := time.NewTicker(30 * time.Second)
defer ticker.Stop()

for {
    <-ticker.C
    alerts := []Notification
    for _, n := range notifications {
      if n.Start == // same year, month, day, hour and minute {
        alerts = append(alerts, n) 
      }
    }

    sendNotifications(alerts)
    // TODO mutate the notifications to avoid duplicatation sending
}

Есть ли более эффективный способ сделать это?

Каков наилучший способ сопоставления по времени, нужно ли мне сравнивать атрибуты time.Now (), такие как год, месяц, день, час и минута, в моем выражении if? то есть уведомление запускается, если были достигнуты год, месяц, день, час и минуты (игнорируются секунды и более)

1 Ответ

0 голосов
/ 08 ноября 2018

Прежде всего, для сравнения значений времени используйте методы Time.Equal , Time.Before и time.After . Сравнение отдельных компонентов совсем не надежно: 

newYork, _ := time.LoadLocation("America/New_York")

t1 := time.Date(2018, 11, 8, 4, 0, 0, 0, time.UTC)
t2 := t1.In(newYork)

fmt.Printf("%v == %v?\n", t1, t2) // 2018-11-08 04:00:00 +0000 UTC == 2018-11-07 23:00:00 -0500 EST?

fmt.Println(t1.Day() == t2.Day()) // false
fmt.Println(t2.Equal(t1))         // true

https://play.golang.org/p/06RcvuI_1Ha

Для задачи планирования я бы использовал time.Timer .

  1. Выясните, какое уведомление появится в следующем
  2. Установите или сбросьте таймер соответственно
    1. После срабатывания таймера перейдите к 1
    2. Если добавлено уведомление, перейдите к 1
    3. Если уведомление удалено, перейдите к 1

Вот эскиз: 

package main

import "time"

func main() {
    t := time.NewTimer(0)

    go func() {
        for range t.C {
            nextTwo := db.GetNextNotifications(2)

            // Sanity check
            if time.Until(nextTwo[0].Start) > 1*time.Second {
                // The timer went off early. Perhaps the notification has been
                // deleted?
                t.Reset(time.Until(nextTwo[0].Start))
                continue
            }

            go send(nextTwo[0])
            t.Reset(time.Until(nextTwo[1].Start))
        }
    }()

    resetTimer(t) // call as required whenever a notification is added or removed
}

func resetTimer(t *time.Timer) {
    next := db.GetNextNotification()
    t.Reset(time.Until(next.Start))
}
...