TimingWheel
0 人感兴趣 · 1 次引用
- 最新
- 推荐
![https://static001.geekbang.org/infoq/a9/a92e2137f55c649796f5051ea3f744a9.jpeg?x-oss-process=image%2Fresize%2Cw_416%2Ch_234](https://static001.geekbang.org/infoq/a9/a92e2137f55c649796f5051ea3f744a9.jpeg?x-oss-process=image%2Fresize%2Cw_416%2Ch_234)
消息队列 Kafka:源码解读 (一)- 异步任务管理
Kafka通过DelayedOperationPurgatory进行异步任务(即DelayedOperation)的管理,在该类的内部对于无法立刻完成的任务则插入内部的多层时钟轮,等待超时处理。
0 人感兴趣 · 1 次引用
Kafka通过DelayedOperationPurgatory进行异步任务(即DelayedOperation)的管理,在该类的内部对于无法立刻完成的任务则插入内部的多层时钟轮,等待超时处理。