schedule

Documentation

Index

• type TimeWheel
  • func New(ticksPerWheel, tickDuration int, timeUnit time.Duration) (*TimeWheel, error)
  • func (tw *TimeWheel) Start()
• type TimeWheelFunc

Types

type TimeWheel

type TimeWheel struct {
	TicksPerWheel int           // 一轮的tick数
	TickDuration  int           // 一个tick的持续时间
	TimeUnit      time.Duration // 时间单位

	Pointer *slot // 当前指针
	// contains filtered or unexported fields
}

func New

func New(ticksPerWheel, tickDuration int, timeUnit time.Duration) (*TimeWheel, error)

//////////////////// 初始化时间盘

func (*TimeWheel) Start

func (tw *TimeWheel) Start()

时间盘开始转动

type TimeWheelFunc

type TimeWheelFunc func(p ...interface{})

方法接口，所有的实现类必须实现该接口