从Kafka的Scala实现抄来的,根据Java语言特性做了一些不得已的修改
算法与实现介绍
https://www.confluent.io/blog/apache-kafka-purgatory-hierarchical-timing-wheels/
SystemTimer的TaskExecutor默认是1个线程运行且不可修改,可能不太合理,依据项目需要可做修改Kafka中的hiResClockMs()方法被我直接修改为System.currentTimeMillis()
| Name | Name | Last commit date | ||
|---|---|---|---|---|
从Kafka的Scala实现抄来的,根据Java语言特性做了一些不得已的修改
算法与实现介绍
https://www.confluent.io/blog/apache-kafka-purgatory-hierarchical-timing-wheels/
SystemTimer的TaskExecutor默认是1个线程运行且不可修改,可能不太合理,依据项目需要可做修改Kafka中的hiResClockMs()方法被我直接修改为System.currentTimeMillis()