Function TestNewAutoExecTimerScheduler

ztimer/timerscheduler_test.go:53–68

采用自动调度器运转时间轮

(t *testing.T)

// 采用自动调度器运转时间轮
func TestNewAutoExecTimerScheduler(t *testing.T) {
	autoTS := NewAutoExecTimerScheduler()

	//给调度器添加Timer
	for i := 0; i < 2000; i++ {
		f := NewDelayFunc(foo, []interface{}{i, i * 3})
		tID, err := autoTS.CreateTimerAfter(f, time.Duration(3*i)*time.Millisecond)
		if err != nil {
			zlog.Error("create timer error", tID, err)
			break
		}
	}

	//阻塞等待
	select {}
}

// 测试取消一个定时器
func TestCancelTimerScheduler(t *testing.T) {