timewheel

Documentation

Index

• type SimpleHandler
• type SimpleTimeWheel
  • func NewSimpleTimeWheel[T any](delay time.Duration, numSlot int, handler SimpleHandler[T]) *SimpleTimeWheel[T]
  • func (t *SimpleTimeWheel[T]) Add(key string, value T, delay time.Duration)
  • func (t *SimpleTimeWheel[T]) Remove(key string)
  • func (t *SimpleTimeWheel[T]) Start()
  • func (t *SimpleTimeWheel[T]) Stop()

Types

type SimpleHandler

type SimpleHandler[T any] func(*SimpleTimeWheel[T], string, T)

处理函数

type SimpleTimeWheel

type SimpleTimeWheel[T any] struct {
	// contains filtered or unexported fields
}

简单时间轮

func NewSimpleTimeWheel

func NewSimpleTimeWheel[T any](delay time.Duration, numSlot int, handler SimpleHandler[T]) *SimpleTimeWheel[T]

func (*SimpleTimeWheel[T]) Add

func (t *SimpleTimeWheel[T]) Add(key string, value T, delay time.Duration)

添加任务

func (*SimpleTimeWheel[T]) Remove

func (t *SimpleTimeWheel[T]) Remove(key string)

func (*SimpleTimeWheel[T]) Start

func (t *SimpleTimeWheel[T]) Start()

启动时间轮任务

func (*SimpleTimeWheel[T]) Stop

func (t *SimpleTimeWheel[T]) Stop()