kafka延時隊列相關操做

TimingWheel是kafka時間輪的實現,內部包含了一個TimerTaskList數組,每一個數組包含了一些鏈表組成的TimerTaskEntry事件,每一個TimerTaskList表示時間輪的某一格,這一格的時間跨度爲tickMs,同一個TimerTaskList中的事件都是相差在一個tickMs跨度內的,整個時間輪的時間跨度爲interval = tickMs * wheelSize,
相關文章
相關標籤/搜索