123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657 |
- package time
- import "errors"
- type Ticker struct {
- C <-chan Time
- r runtimeTimer
- }
- func NewTicker(d Duration) *Ticker {
- if d <= 0 {
- panic(errors.New("non-positive interval for NewTicker"))
- }
-
-
-
- c := make(chan Time, 1)
- t := &Ticker{
- C: c,
- r: runtimeTimer{
- when: when(d),
- period: int64(d),
- f: sendTime,
- arg: c,
- },
- }
- startTimer(&t.r)
- return t
- }
- func (t *Ticker) Stop() {
- stopTimer(&t.r)
- }
- func Tick(d Duration) <-chan Time {
- if d <= 0 {
- return nil
- }
- return NewTicker(d).C
- }
|