TimingWheel wheel = new SimpleTimingWheel(256,1,new DelayQueue());
TimingWheelTimer timer = new TimingWheelTimer(wheel,executorService);
timer.start();
timer.add(timingEntry)-
Notifications
You must be signed in to change notification settings - Fork 0
fatcarter/TimingWheel
Folders and files
| Name | Name | Last commit message | Last commit date | |
|---|---|---|---|---|
Repository files navigation
About
模拟kafka逻辑实现的内存时间轮
Resources
Stars
Watchers
Forks
Releases
No releases published
Packages 0
No packages published