Function newTimerWheel

timer/timer_wheel.go:18–38

(ms_unit uint64, bit_size uint32, now uint64, p *timerPool)

}

func newTimerWheel(ms_unit uint64, bit_size uint32, now uint64, p *timerPool) *timerWheel {
	timer_wheel := &timerWheel{
		index:      0,
		bitSize:    bit_size,
		msUnit:     ms_unit,
		next_wheel: nil,
		prev_wheel: nil,
	}

	if ms_unit == 1 {
		timer_wheel.baseTick = now
	} else {
		timer_wheel.baseTick = now + ms_unit
	}

	for i := 0; i < TIMERSLOTSCOUNT; i++ {
		timer_wheel.array[i] = newTimerList(p)
	}

	return timer_wheel
}

func (this *timerWheel) tickIdxDelta(runTick uint64) uint8 {
	idxDelta := runTick - this.baseTick