timewheel

Documentation

Index

• type Delay
  • func NewDelay() *Delay
  • func (d *Delay) Add(interval time.Duration, key string, callback func())
  • func (d *Delay) AddAt(expire time.Time, key string, callback func())
  • func (d *Delay) Cancel(key string)
• type TimeWheel
  • func New(interval time.Duration, slotNum int) *TimeWheel
  • func (tw *TimeWheel) Add(delay time.Duration, key string, callback func())
  • func (tw *TimeWheel) Cancel(key string)
  • func (tw *TimeWheel) Start()
  • func (tw *TimeWheel) Stop()

Types

type Delay

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

func NewDelay

func NewDelay() *Delay

func (*Delay) Add

func (d *Delay) Add(interval time.Duration, key string, callback func())

添加延迟任务 相对时间

func (*Delay) AddAt

func (d *Delay) AddAt(expire time.Time, key string, callback func())

添加延迟任务 绝对时间

func (*Delay) Cancel

func (d *Delay) Cancel(key string)

取消延迟任务

type TimeWheel

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

循环队列 + 链表

func New

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

func (*TimeWheel) Add

func (tw *TimeWheel) Add(delay time.Duration, key string, callback func())

func (*TimeWheel) Cancel

func (tw *TimeWheel) Cancel(key string)

func (*TimeWheel) Start

func (tw *TimeWheel) Start()

func (*TimeWheel) Stop

func (tw *TimeWheel) Stop()