kafka延时队列相关操做

TimingWheel是kafka时间轮的实现,内部包含了一个TimerTaskList数组,每一个数组包含了一些链表组成的TimerTaskEntry事件,每一个TimerTaskList表示时间轮的某一格,这一格的时间跨度为tickMs,同一个TimerTaskList中的事件都是相差在一个tickMs跨度内的,整个时间轮的时间跨度为interval = tickMs * wheelSize,
相关文章
相关标签/搜索