type TimingWheel struct {
    ticker          *time.Ticker
    tickMs          int          // 时间刻度
    wheelSize       int          // 时间轮大小
    currentPosition int          // 轮盘上的指针位置
    level           int          // 时间轮层数
    prevWheel       *TimingWheel // 上层时间轮
    nextWheel       *TimingWheel // 下层时间轮
    slots           []*Slot      // 队列
    stopChannel     chan bool
}


func (e *TimingWheel) addTask(duration int, task *Task) {


    // 如果添加的刻度大于当前的时间轮刻度, 进入下一轮
    if duration > e.wheelSize*e.tickMs {
        if e.nextWheel == nil {
                newTw := newTimingWheel(
                        e.tickMs*e.wheelSize,
                        e.wheelSize,
                        e.level+1,
                        e,
                )
                e.nextWheel = newTw
        }
        e.nextWheel.addTask(duration-e.wheelSize*e.tickMs, task)
    } else {
        e.moveTask(duration, task)
    }
}




func (e *TimingWheel) AddTask(duration int, job func()) {
    expiration := GetNowTimestamp() + int64(duration)
    e.addTask(duration, &Task{expiration, job})
}

func (e *TimingWheel) advance() {
    fmt.Println("advance", e.currentPosition, e.level)
    slot := e.slots[e.currentPosition]


    if e.level == 0 {
        // 表示第一层时间轮


        // 当前刻度队列中的任务全部取出并执行   
        slot.trigger()
    } else {
        // 表示进入到下一层


        // 将队列中的定时任务取出来
        tasks := slot.getClear()


        // 当前时间戳
        currentTime := GetNowTimestamp()


        // 将任务转移到上一层队列中
        for t := tasks.Front(); t != nil; t = t.Next() {
            t := t.Value.(*Task)
            e.prevWheel.moveTask(int(t.expiration-currentTime), t)
        }
    }


    // 往前走一步
    e.currentPosition = (e.currentPosition + 1) % e.wheelSize


    if e.currentPosition == 0 {
        // 当下一层存在时
        if e.nextWheel != nil {
            e.nextWheel.advance()
        }
    }
}


// 时间轮添加到队列中的任务
func (e *TimingWheel) moveTask(duration int, task *Task) {
    if duration <= 0 {
        e.slots[e.currentPosition].add(task)
        return
    }
    // 选择刻度所在的队列位置，并添加任务到队列中
    index := (int(duration/e.tickMs) + e.currentPosition) % e.wheelSize
    e.slots[index].add(task)
}