如何在 Java 中利用 while 循环实现一个简单的基于时间轮算法的定时任务调度流程-java教程-PHP中文网

可行但仅适用于学习、嵌入式或教学场景；生产环境应优先选用HashedWheelTimer、ScheduledThreadPoolExecutor或Quartz。

java 中用 while 循环模拟时间轮（timing wheel）调度器是可行的，但需注意：真实生产环境应优先选用 hashedwheeltimer（netty）、scheduledthreadpoolexecutor 或 quartz；而纯 while + 时间轮逻辑适合学习原理、嵌入式轻量场景或教学演示。

理解时间轮的核心结构

时间轮不是“实时计算下次执行时间”，而是把时间切分成固定刻度（tick），每个刻度对应一个任务槽（bucket）。任务按其延迟时间映射到对应槽位，主循环每 tick 检查当前槽，触发其中所有任务。

关键参数：

tickDuration：每格代表多少毫秒（如 100ms）
ticksPerWheel：一圈多少格（如 64）→ 总时间跨度 = tickDuration × ticksPerWheel
currentTime：当前轮次的基准时间（毫秒级，通常对齐 tickDuration 的整数倍）

用 while 实现单层时间轮主循环

以下是一个简化但可运行的单层时间轮调度器骨架（无线程安全、无过期重试，聚焦流程）：

public class SimpleTimingWheel {
    private final long tickDuration;     // 100ms
    private final int ticksPerWheel;     // 64
    private final List<runnable>[] wheel;
    private volatile long currentTime;     // 当前 tick 开始时间（毫秒）
<pre class="brush:php;toolbar:false;">@SuppressWarnings("unchecked")
public SimpleTimingWheel(long tickDuration, int ticksPerWheel) {
    this.tickDuration = tickDuration;
    this.ticksPerWheel = ticksPerWheel;
    this.wheel = new List[ticksPerWheel];
    for (int i = 0; i ();
    }
    this.currentTime = System.currentTimeMillis() - (System.currentTimeMillis() % tickDuration);
}

// 添加延迟任务（仅支持 ≤ 一圈时长的任务）
public void addTask(Runnable task, long delayMs) {
    if (delayMs = tickDuration * ticksPerWheel) {
        throw new IllegalArgumentException("Delay out of range");
    }
    long expiration = System.currentTimeMillis() + delayMs;
    long tick = (expiration - currentTime) / tickDuration;
    int idx = (int) (tick % ticksPerWheel);
    wheel[idx].add(task);
}

// 主循环：持续推进时间，每 tick 执行一次
public void start() {
    Thread t = new Thread(() -> {
        while (!Thread.currentThread().isInterrupted()) {
            long now = System.currentTimeMillis();
            long expectedTime = currentTime + tickDuration;

            // 等待到下一个 tick 开始时刻（避免 busy-wait）
            if (now  tasks = wheel[idx];
            for (Runnable task : tasks) {
                task.run();
            }
            tasks.clear(); // 清空已执行任务
        }
    });
    t.setDaemon(true);
    t.start();
}

}

使用示例与注意事项

调用方式：

Java注释规范Skills

当用户要求为 Java 代码添加注释、修改注释、审查注释、整理注释格式，或要求按照代码注释规范处理 Java 文件时，使用本技能。本技能用于统一生成和维护 Java 类注释模板、按 Git 对比 release 判断版本号、补充每行代码上方中文块注释、调整注释空行规则，并保持 Java 文件 UTF-8 无 BOM 编码。典型触发场景包括：补充类注释、更新 @version、检查 @author 来源、整理行尾注释、把注释放到代码上一行、检查注释是否符合规范、构建前检查 Java 注释风格。

下载

SimpleTimingWheel wheel = new SimpleTimingWheel(100, 64);
wheel.addTask(() -> System.out.println("Hello at " + System.currentTimeMillis()), 300); // 300ms 后执行
wheel.addTask(() -> System.out.println("World!"), 800); // 800ms 后执行
wheel.start();
<p>// 主线程保持运行（否则 JVM 退出）
Thread.sleep(2000);</p>

需注意：

精度限制：最小延迟单位为 tickDuration，350ms 任务实际在 400ms 后触发
单圈限制：上述实现只支持延迟 ≤ 一圈总时长的任务。如需更大范围，需升级为多层时间轮（如小时轮+分钟轮+秒轮）
线程安全：addTask() 和主循环不在同一线程，实际中需加锁（如 synchronized 或 ReentrantLock）或使用线程安全集合
异常隔离：某个任务抛异常不应中断整个 while 循环，应在 task.run() 外包裹 try-catch