timingwheel

Documentation

Index

• type Timer
• type TimingWheel
  • func New(interval time.Duration) *TimingWheel
  • func (w *TimingWheel) AddTimer(d time.Duration, callback func() error) error
  • func (w *TimingWheel) Start()
  • func (w *TimingWheel) Stop()

Types

type Timer

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

Timer 表示计时器

type TimingWheel

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

TimingWheel 实现时间轮

func New

func New(interval time.Duration) *TimingWheel

New 创建时间轮

func (*TimingWheel) AddTimer

func (w *TimingWheel) AddTimer(d time.Duration, callback func() error) error

AddTimer 向时间轮中添加一个计时器

func (*TimingWheel) Start

func (w *TimingWheel) Start()

Start 启动时间轮

func (*TimingWheel) Stop

func (w *TimingWheel) Stop()

Stop 停止时间轮