Java中常见延时队列的实现方案总结

在Java中，实现常用的延时队列可以通过DelayQueue来实现。DelayQueue是一个无界队列，它使用PriorityQueue来保证队列中元素的顺序，并且只有在延时到期时才能从队列中取出元素。

以下是一个使用DelayQueue的简单示例：

import java.util.concurrent.DelayQueue;
import java.util.concurrent.Delayed;
import java.util.concurrent.TimeUnit;
 
public class DelayQueueExample {
 
    public static void main(String[] args) throws InterruptedException {
        DelayQueue<DelayedTask> delayQueue = new DelayQueue<>();
 
        // 添加任务，延时3秒
        delayQueue.put(new DelayedTask("Task 1", 3));
        delayQueue.put(new DelayedTask("Task 2", 5));
        delayQueue.put(new DelayedTask("Task 3", 1));
 
        // 循环处理任务
        while (!delayQueue.isEmpty()) {
            DelayedTask task = delayQueue.poll();
            if (task != null) {
                System.out.println("Processing task: " + task.getName() + ", delay: " + task.getDelay(TimeUnit.SECONDS) + " seconds");
                // 处理任务的逻辑
                // ...
            }
        }
    }
 
    static class DelayedTask implements Delayed {
        private String name;
        private long expireTime;
 
        public DelayedTask(String name, int delaySeconds) {
            this.name = name;
            this.expireTime = System.nanoTime() + TimeUnit.NANOSECONDS.convert(delaySeconds, TimeUnit.SECONDS);
        }
 
        @Override
        public long getDelay(TimeUnit unit) {
            return unit.convert(this.expireTime - System.nanoTime(), TimeUnit.NANOSECONDS);
        }
 
        @Override
        public int compareTo(Delayed o) {
            DelayedTask other = (DelayedTask) o;
            return Long.compare(this.expireTime, other.expireTime);
        }
 
        public String getName() {
            return name;
        }
    }
}

在这个示例中，我们定义了一个DelayedTask类，它实现了Delayed接口。这个类有一个延时到期的时间，通过实现getDelay方法来返回剩余的延时时间。compareTo方法则定义了任务之间的优先级，以确定队列中的顺序。主函数中创建了DelayQueue，并添加了几个延时任务。然后，它在循环中不断从队列中取出并处理任务。