DDMQ icon indicating copy to clipboard operation
DDMQ copied to clipboard

Chronos 内置的时间轮服务是哪个代码?

Open flylee85 opened this issue 3 years ago • 1 comments

flylee85 avatar Mar 18 '21 14:03 flylee85

@flylee85 你说的是MqPushService.java吧。 其实不是严格的时间轮实现,而是根据当前的seekTimestamp去逐个seek。

 // 迭代出当前 seekTimestamp 下所有数据
        int count = 0;
        try (RocksIterator it = RDB.newIterator(CFManager.CFH_DEFAULT)) {
             // more code
        }

SchopenhauerZhang avatar Oct 10 '23 02:10 SchopenhauerZhang