Java中的DelayQueue poll()方法及其示例

Java中的DelayQueue是一种带有延迟时间的队列，可以用于实现定时执行任务的功能。该队列中的元素必须实现Delayed接口，并含有指定的延迟时间，元素会按照延迟时间的长短进行排序，延迟时间最短的元素会被最先取出。

DelayQueue提供了poll()方法来获取队列中的元素，本篇文章将对poll()方法进行详细介绍，并提供具体的示例代码。

DelayQueue poll()方法

poll()方法是DelayQueue中用来获取队列中元素的方法，它会将队列中延迟时间最短的元素取出，并从队列中删除该元素。如果队列为空，则返回null。

poll()方法的方法签名如下：

public E poll()

其中，E代表元素的类型。

下面是一个使用poll()方法的示例：

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

public class DelayQueueDemo {
    public static void main(String[] args) {
        DelayQueue<MyDelayed> queue = new DelayQueue<>();
        long now = System.currentTimeMillis();
        queue.put(new MyDelayed("task1", now + 1000));
        queue.put(new MyDelayed("task2", now + 500));
        queue.put(new MyDelayed("task3", now + 1500));

        while (true) {
            MyDelayed task = queue.poll();
            if (task == null) {
                break;
            }
            System.out.println(task.getName() + " running at " + System.currentTimeMillis());
        }
    }
}

class MyDelayed implements Delayed {
    private String name;
    private long executeTime;

    public MyDelayed(String name, long executeTime) {
        this.name = name;
        this.executeTime = executeTime;
    }

    public String getName() {
        return name;
    }

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

    @Override
    public int compareTo(Delayed o) {
        return (int) (this.executeTime - ((MyDelayed) o).executeTime);
    }
}

在上述示例代码中，我们创建了一个DelayQueue，向其中添加了三个带有延迟时间的元素。然后我们使用poll()方法从队列中取出元素，如果队列为空则退出循环，如果队列不为空则输出当前正在执行的任务名和执行时间。