Delayqueue的用法

DelayQueue是Java的一个并发集合类，它实现了延迟队列，即只有在一定时间后才能从队列中获取元素。它的作用是在多线程应用程序中实现定时任务和调度任务。

以下是使用DelayQueue的基本步骤：

1. 创建一个实现Delayed接口的任务类，该接口定义了getDelay()方法，表示任务的延迟时间。

2. 创建一个DelayQueue对象，将任务添加到DelayQueue中。

3. 创建一个线程池，从DelayQueue中获取任务并执行。

4. 在任务的getDelay()方法返回0时，任务会被从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) {
        DelayQueue<DelayedTask> queue = new DelayQueue<>();
        queue.add(new DelayedTask("task 1", 2, TimeUnit.SECONDS));
        queue.add(new DelayedTask("task 2", 4, TimeUnit.SECONDS));
        queue.add(new DelayedTask("task 3", 6, TimeUnit.SECONDS));

        Thread thread = new Thread(() -> {
            while (true) {
                try {
                    DelayedTask task = queue.take();
                    System.out.println("Execute task: " + task.getName());
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        });

        thread.start();
    }
}

class DelayedTask implements Delayed {
    private String name;
    private long delayTime;
    private long startTime;

    public DelayedTask(String name, long delayTime, TimeUnit unit) {
        this.name = name;
        this.delayTime = unit.toNanos(delayTime);
        this.startTime = System.nanoTime() + this.delayTime;
    }

    public String getName() {
        return name;
    }

    @Override
    public long getDelay(TimeUnit unit) {
        return unit.convert(startTime - System.nanoTime(), TimeUnit.NANOSECONDS);
    }

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

在这个例子中，我们创建了一个DelayQueue对象，并向其中添加了三个DelayedTask对象，分别在2秒、4秒和6秒后执行。我们还创建了一个线程，从DelayQueue中取出任务并执行。在DelayedTask的getDelay方法中，我们使用了System.nanoTime()方法获取当前时间，然后将任务的开始时间减去当前时间，得到任务的延迟时间。当任务的getDelay方法返回0时，它将从DelayQueue中移除，并被执行。