kafka源码
0 人感兴趣 · 1 次引用
- 最新
- 推荐
消息队列 Kafka:源码解读 (一)- 异步任务管理
Kafka通过DelayedOperationPurgatory进行异步任务(即DelayedOperation)的管理,在该类的内部对于无法立刻完成的任务则插入内部的多层时钟轮,等待超时处理。
0 人感兴趣 · 1 次引用
Kafka通过DelayedOperationPurgatory进行异步任务(即DelayedOperation)的管理,在该类的内部对于无法立刻完成的任务则插入内部的多层时钟轮,等待超时处理。