time.Ticker
func main() {
hub = NewAppSocketHub()
ticker := time.NewTicker(time.Second)
go func() {
for {
log.Printf("In loop")
select {
case <-ticker.C:
log.Printf("Broadcasting to %d clients", len(hub.Clients))
hub.Broadcast <- UpdatePayload{
InstanceID: "Test",
Status: "running",
}
}
}
log.Printf("Out of loop")
}()
r := chi.NewRouter()
r.Use(render.SetContentType(render.ContentTypeJSON))
r.Use(Cors)
r.Post("/auth/login", Login)
r.HandleFunc("/ws", WebSocketEcho)
// ...
http.ListenAndServe(":9000", r)
log.Printf("Ended...")
}
NewAppSocketHub
2017/06/14 16:08:05 In loop
2017/06/14 16:08:06 Broadcasting to 0 clients
它似乎循环中断? 怎么了?