Golang 版本时间轮定时器

项目地址

package main

import (
    "github.com/ouqiang/timewheel"
    "time"
    "fmt"
)

func main()  {
    // tick 刻度为 1 秒, 3600 个槽, 执行的 job
    tw := timewheel.New(1 * time.Second, 3600, func(data []interface{}) {
        fmt.Println(data)
        // do something
    })
    tw.Start()
    tw.Add(5 * time.Second, []interface{}{1})
    tw.Add(10 * time.Minute, []interface{}{2})
    tw.Add(35 * time.Hour, []interface{}{3})
    // 停止
    tw.Stop()
}