timingwheel

Documentation

Index

• Variables
• type Task
  • func (s *Task) Callback(f func())
  • func (s *Task) Cancel()
  • func (s *Task) TTL() int64
• type TimingWheel
  • func NewTimingWheel(interval time.Duration, wheels int, slots int) *TimingWheel
  • func (w *TimingWheel) After(timeout time.Duration) *Task
  • func (w *TimingWheel) Stop()

Variables

var Executor = func(f func()) {
	go f()
}

Types

type Task

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

func (*Task) Callback

func (s *Task) Callback(f func())

func (*Task) Cancel

func (s *Task) Cancel()

func (*Task) TTL

func (s *Task) TTL() int64

type TimingWheel

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

TimingWheel the timing wheel ticker implementation

func NewTimingWheel

func NewTimingWheel(interval time.Duration, wheels int, slots int) *TimingWheel

func (*TimingWheel) After

func (w *TimingWheel) After(timeout time.Duration) *Task

func (*TimingWheel) Stop

func (w *TimingWheel) Stop()