java DelayQueue 延时队列

Java中的DelayQueue是一个特殊的队列，它只允许在指定的延迟时间之后才能从队列中取出元素。可以使用DelayQueue来实现一些延迟任务的功能，例如任务调度、缓存过期等。

DelayQueue基于PriorityQueue实现，但是它的元素必须实现Delayed接口，Delayed接口中定义了一个getDelay()方法，返回元素的延迟时间。

当从DelayQueue中取出元素时，如果该元素的延迟时间还没有到达，则该元素会被重新加入队列中，直到延迟时间到达。

以下是一个简单的使用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<DelayedElement> delayQueue = new DelayQueue<DelayedElement>();
        delayQueue.add(new DelayedElement("element1", 2000));
        delayQueue.add(new DelayedElement("element2", 5000));
        delayQueue.add(new DelayedElement("element3", 1000));

        while (!delayQueue.isEmpty()) {
            DelayedElement element = delayQueue.take();
            System.out.println("Taking element: " + element);
        }
    }

    static class DelayedElement implements Delayed {
        private String name;
        private long delayTime;

        public DelayedElement(String name, long delayTime) {
            this.name = name;
            this.delayTime = System.currentTimeMillis() + delayTime;
        }

        @Override
        public long getDelay(TimeUnit unit) {
            long diff = delayTime - System.currentTimeMillis();
            return unit.convert(diff, TimeUnit.MILLISECONDS);
        }

        @Override
        public int compareTo(Delayed o) {
            if (this.delayTime < ((DelayedElement) o).delayTime) {
                return -1;
            }
            if (this.delayTime > ((DelayedElement) o).delayTime) {
                return 1;
            }
            return 0;
        }

        @Override
        public String toString() {
            return "DelayedElement{" +
                    "name='" + name + '\'' +
                    ", delayTime=" + delayTime +
                    '}';
        }
    }
}

在上面的例子中，我们创建了一个DelayQueue，并向其中添加了三个DelayedElement元素。每个元素都有一个延迟时间，分别为2秒、5秒和1秒。

在主线程中，我们不断地从DelayQueue中取出元素，直到队列为空。当元素的延迟时间还没有到达时，它会被重新加入队列中，直到延迟时间到达。