timewheel

cluster-timewheel

介绍

go实现的时间轮，可单机可分布式

安装

go get gitee.com/burybell/cluster-timewheel@v1.0.0

案例

单机

package main

import (
	"fmt"
	timewheel "gitee.com/burybell/cluster-timewheel"
	"time"
)

const (
	Call1 timewheel.CallId = iota
)

func init() {

	timewheel.AddCall(Call1, func(ctx *timewheel.Context) {
		fmt.Println("call1", ctx.String())
	})

}

func main() {

	local := timewheel.NewLocal(time.Second, 60)

	local.Run()

	for i := 0; i < 1000; i++ {
		context := timewheel.NewContext("cl1")
		local.AddTimer(time.Second*time.Duration(i), fmt.Sprintf("id-%d", i), context, Call1)
	}

	select {}
}

分布式

package main

import (
	"fmt"
	timewheel "gitee.com/burybell/cluster-timewheel"
	"github.com/go-redis/redis"
	"time"
)

const (
	Call1 timewheel.CallId = iota
)

func init() {

	timewheel.AddCall(Call1, func(ctx *timewheel.Context) {
		fmt.Println("call1", ctx.String())
	})

}

func main() {

	client := redis.NewClient(&redis.Options{Addr: "127.0.0.1:6379"})
	cluster := timewheel.NewCluster(client, timewheel.Options{
		Key:      "test",
		Interval: time.Second,
		SlotNums: 60,
	})

	cluster.Run()

	for i := 0; i < 1000; i++ {
		context := timewheel.NewContext("cl1")
		cluster.AddTimer(time.Second*time.Duration(i), fmt.Sprintf("id-%d", i), context, Call1)
	}

	select {}
}