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

Method CreateTimerAfter

ztimer/timerscheduler.go:74–80  ·  view source on GitHub ↗

CreateTimerAfter 创建一个延迟Timer 并将Timer添加到分层时间轮中, 返回Timer的tID

(df *DelayFunc, duration time.Duration)

Source from the content-addressed store, hash-verified

72
73// CreateTimerAfter 创建一个延迟Timer 并将Timer添加到分层时间轮中, 返回Timer的tID
74func (ts *TimerScheduler) CreateTimerAfter(df *DelayFunc, duration time.Duration) (uint32, error) {
75 ts.Lock()
76 defer ts.Unlock()
77
78 ts.IDGen++
79 return ts.IDGen, ts.tw.AddTimer(ts.IDGen, NewTimerAfter(df, duration))
80}
81
82// CancelTimer 删除timer
83func (ts *TimerScheduler) CancelTimer(tID uint32) {

Callers 3

TestNewTimerSchedulerFunction · 0.95
TestCancelTimerSchedulerFunction · 0.80

Calls 2

NewTimerAfterFunction · 0.85
AddTimerMethod · 0.80

Tested by 3

TestNewTimerSchedulerFunction · 0.76
TestCancelTimerSchedulerFunction · 0.64