java時間輪如何實現

Java中的時間輪算法通常用于實現高效的定時任務調度。它通過將時間分成若干個時間間隔（稱為“刻度”），并將任務存儲在這些刻度上，從而實現快速查找和調度任務。以下是一個簡單的Java時間輪實現示例：

import java.util.ArrayList;
import java.util.List;

public class TimingWheel {
    private final int wheelSize;
    private final long interval;
    private List<Task> tasks;
    private int currentIndex;

    public TimingWheel(int wheelSize, long interval) {
        this.wheelSize = wheelSize;
        this.interval = interval;
        this.tasks = new ArrayList<>(wheelSize);
        this.currentIndex = 0;
    }

    public void addTask(Task task) {
        tasks.add(task);
    }

    public void tick() {
        currentIndex = (currentIndex + 1) % wheelSize;
        List<Task> expiredTasks = tasks.subList(currentIndex, wheelSize);
        for (Task task : expiredTasks) {
            task.run();
        }
    }

    public static void main(String[] args) {
        TimingWheel timingWheel = new TimingWheel(60, 1000); // 每秒一個刻度，每個刻度1000毫秒

        for (int i = 0; i < 10; i++) {
            final int taskId = i;
            timingWheel.addTask(new Task() {
                @Override
                public void run() {
                    System.out.println("Task " + taskId + " executed at " + System.currentTimeMillis());
                }
            });
        }

        while (true) {
            timingWheel.tick();
            try {
                Thread.sleep(500); // 每500毫秒執行一次tick方法
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

abstract class Task {
    abstract void run();
}

這個示例中，我們創建了一個名為TimingWheel的類，它包含一個固定大小的輪詢數組tasks，以及一個表示當前刻度的索引currentIndex。我們還定義了一個名為Task的抽象類，用于表示要執行的任務。

addTask方法用于向輪詢數組中添加任務，tick方法用于處理過期任務。在main方法中，我們創建了一個TimingWheel實例，并向其中添加了10個任務。然后，我們使用一個無限循環來定期執行tick方法，以便在指定的時間間隔內執行這些任務。

請注意，這個示例僅用于演示目的，實際應用中可能需要根據具體需求進行調整。例如，你可能需要實現一個更復雜的任務調度策略，或者使用多個時間輪來處理不同時間粒度的任務。