/TimingWheel

模拟kafka逻辑实现的内存时间轮

Primary LanguageJava

TimingWheel wheel = new SimpleTimingWheel(256,1,new DelayQueue());
TimingWheelTimer timer = new TimingWheelTimer(wheel,executorService);
timer.start();
timer.add(timingEntry)