timewheel

package

v1.2.3 Latest Latest Go to latest Published: May 9, 2021 License: GPL-3.0 Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

func At(at time.Time, key string, job func())

func Cancel(key string)

func Delay(duration time.Duration, key string, job func())

type Task struct {
	// contains filtered or unexported fields
}

type TimeWheel struct {
	// contains filtered or unexported fields
}

func New(interval time.Duration, slotNum int) *TimeWheel

func (tw *TimeWheel) AddTimer(delay time.Duration, key string, job func())

func (tw *TimeWheel) RemoveTimer(key string)

func (tw *TimeWheel) Start()

func (tw *TimeWheel) Stop()