ticker.go 341 B

123456789101112131415161718192021
  1. package timer
  2. import (
  3. "sync"
  4. "time"
  5. )
  6. type SubTicker struct {
  7. ChanTicker chan struct{}
  8. Cb func()
  9. Ticker *time.Ticker
  10. QuitChan chan struct{}
  11. Wg sync.WaitGroup
  12. }
  13. func NewSubTicker(len int) *SubTicker {
  14. t := new(SubTicker)
  15. t.ChanTicker = make(chan struct{}, len)
  16. t.QuitChan = make(chan struct{})
  17. return t
  18. }