Merge branch 'tickers'

This commit is contained in:
Mark McGranaghan
2019-09-01 16:24:40 -07:00
3 changed files with 35 additions and 9 deletions

View File

@@ -16,9 +16,16 @@ func main() {
// `range` builtin on the channel to iterate over
// the values as they arrive every 500ms.
ticker := time.NewTicker(500 * time.Millisecond)
done := make(chan bool)
go func() {
for t := range ticker.C {
fmt.Println("Tick at", t)
for {
select {
case <-done:
return
case t := <-ticker.C:
fmt.Println("Tick at", t)
}
}
}()
@@ -27,5 +34,6 @@ func main() {
// channel. We'll stop ours after 1600ms.
time.Sleep(1600 * time.Millisecond)
ticker.Stop()
done <- true
fmt.Println("Ticker stopped")
}

View File

@@ -1,2 +1,2 @@
7dc6447323f493f72aa70952bf3e3f2c6156f82f
Rgc_UDvHv6a
c83f34821c69d156713919a42c73ec9f58560f72
IUmkvvXL5Ok