CreateTimerAfter 创建一个延迟Timer 并将Timer添加到分层时间轮中, 返回Timer的tID
(df *DelayFunc, duration time.Duration)
| 72 | |
| 73 | // CreateTimerAfter 创建一个延迟Timer 并将Timer添加到分层时间轮中, 返回Timer的tID |
| 74 | func (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 |
| 83 | func (ts *TimerScheduler) CancelTimer(tID uint32) { |