cherryTimeWheel

Apr 7, 2023

Changes in this version

+ func MSToTime(t int64) time.Time

+ func NextId() uint64

+ func TimeToMS(t time.Time) int64

+ type DelayQueue struct

+ C chan interface{}

+ func NewDelayQueue(size int) *DelayQueue

+ func (dq *DelayQueue) Offer(elem interface{}, expiration int64)

+ func (dq *DelayQueue) Poll(exitC chan struct{}, nowF func() int64)

+ type EverySchedule struct

+ Interval time.Duration

+ func (s *EverySchedule) Next(prev time.Time) time.Time

+ type FixedDateSchedule struct

+ Hour int

+ Minute int

+ Second int

+ func (s *FixedDateSchedule) Next(prev time.Time) time.Time

+ type Scheduler interface

+ Next func(time.Time) time.Time

+ type TimeWheel struct

+ func NewTimeWheel(tick time.Duration, wheelSize int64) *TimeWheel

+ func (tw *TimeWheel) AddEveryFunc(id uint64, d time.Duration, f func(), async ...bool) *Timer

+ func (tw *TimeWheel) AfterFunc(id uint64, d time.Duration, f func(), async ...bool) *Timer

+ func (tw *TimeWheel) BuildAfterFunc(d time.Duration, f func()) *Timer

+ func (tw *TimeWheel) BuildEveryFunc(d time.Duration, f func(), async ...bool) *Timer

+ func (tw *TimeWheel) NextId() uint64

+ func (tw *TimeWheel) ScheduleFunc(id uint64, s Scheduler, f func(), async ...bool) *Timer

+ func (tw *TimeWheel) Start()

+ func (tw *TimeWheel) Stop()

+ type Timer struct

+ func (t *Timer) ID() uint64

+ func (t *Timer) Stop() bool