Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- manager := &Manager{
- ticker: time.NewTicker(updateInterval),
- }
- go func() {
- for {
- select {
- case t := <-manager.ticker.C:
- glog.Info("[PACER] line ", lineID, " update tick ", t)
- before := time.Now()
- manager.update(t, feedbackWatchdog.IsHungry())
- glog.Info("[PACER] line ", lineID, " update tick took ", time.Now().Sub(before))
- case <-shutdownChan:
- glog.Warning("[PACER] line ", lineID, " update tick loop exiting")
- break
- }
- }
- }()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement