MCPcopy
hub / github.com/aceld/zinx / NewAutoExecTimerScheduler

Function NewAutoExecTimerScheduler

ztimer/timerscheduler.go:120–135  ·  view source on GitHub ↗

NewAutoExecTimerScheduler 时间轮定时器 自动调度

()

Source from the content-addressed store, hash-verified

118
119// NewAutoExecTimerScheduler 时间轮定时器 自动调度
120func NewAutoExecTimerScheduler() *TimerScheduler {
121 //创建一个调度器
122 autoExecScheduler := NewTimerScheduler()
123 //启动调度器
124 autoExecScheduler.Start()
125
126 //永久从调度器中获取超时 触发的函数 并执行
127 go func() {
128 delayFuncChan := autoExecScheduler.GetTriggerChan()
129 for df := range delayFuncChan {
130 go df.Call()
131 }
132 }()
133
134 return autoExecScheduler
135}

Callers 2

TestCancelTimerSchedulerFunction · 0.85

Calls 4

StartMethod · 0.95
GetTriggerChanMethod · 0.95
NewTimerSchedulerFunction · 0.85
CallMethod · 0.65

Tested by 2

TestCancelTimerSchedulerFunction · 0.68