Java中的 DelayQueue add() 方法及示例

Java中的DelayQueue是一个实现了延迟队列的类，可以让我们实现一个具有延迟操作的队列。其中，add()方法是DelayQueue类中用来往队列中插入元素的方法。本文将介绍DelayQueue add()方法的用法及示例代码。

方法说明

以下为DelayQueue add()方法的声明：

public boolean add(E e)

该方法用于将指定元素插入到此队列中。如果插入元素成功，则返回true，否则如果队列已满，则抛出IllegalStateException异常。

示例代码

下面的示例代码演示了如何使用DelayQueue add()方法将一些元素插入到队列中：

import java.util.concurrent.DelayQueue;
import java.util.concurrent.Delayed;
import java.util.concurrent.TimeUnit;

public class DelayQueueAddExample {

    public static void main(String[] args) throws InterruptedException {
        DelayQueue<DelayedElement> delayQueue = new DelayQueue<>();

        // 向队列中插入10个元素，每个元素的延迟时间不同
        for (int i = 1; i <= 10; i++) {
            delayQueue.add(new DelayedElement(i, i * 1000L));
        }

        // 等待队列中的元素到期，然后将它们从队列中取出
        while (!delayQueue.isEmpty()) {
            DelayedElement element = delayQueue.take();
            System.out.println("取出元素：" + element);
        }
    }

    static class DelayedElement implements Delayed {
        private final int id;
        private final long expireTime;

        public DelayedElement(int id, long delay) {
            this.id = id;
            this.expireTime = System.currentTimeMillis() + delay;
        }

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

        @Override
        public int compareTo(Delayed o) {
            return Long.compare(this.expireTime, ((DelayedElement) o).expireTime);
        }

        @Override
        public String toString() {
            return "DelayedElement{" +
                    "id=" + id +
                    ", expireTime=" + expireTime +
                    '}';
        }
    }
}

在以上示例代码中，我们先创建了一个DelayQueue对象，然后使用add()方法将10个不同的DelayedElement对象插入到队列中，每个元素的延迟时间都不同。接着，我们使用take()方法从队列中取出元素，直到队列为空。

运行上述示例代码，我们可以看到输出的结果如下：

取出元素：DelayedElement{id=1, expireTime=1630980285503}
取出元素：DelayedElement{id=2, expireTime=1630980286504}
取出元素：DelayedElement{id=3, expireTime=1630980287503}
取出元素：DelayedElement{id=4, expireTime=1630980288504}
取出元素：DelayedElement{id=5, expireTime=1630980289505}
取出元素：DelayedElement{id=6, expireTime=1630980290506}
取出元素：DelayedElement{id=7, expireTime=1630980291504}
取出元素：DelayedElement{id=8, expireTime=1630980292505}
取出元素：DelayedElement{id=9, expireTime=1630980293505}
取出元素：DelayedElement{id=10, expireTime=1630980294506}

可以看到，每个元素被取出的时间，与它们插入队列的时间间隔正好等于设置的延迟时间。这说明DelayQueue add()方法能够很好地实现队列中元素的延迟操作。

总结

DelayQueue add()方法是Java中实现延迟队列中插入元素的方法，可以非常方便地实现队列中元素的延迟操作。在实际开发中，我们可以根据具体的需求使用该方法，实现各种有用的延迟操作。