java延迟队列怎么应用

Java延迟队列（DelayQueue）是一个实现了Delayed接口的无界阻塞队列，其中的元素只能在其到期时才能被取出。

延迟队列可以用于定时任务调度，可以将需要延迟执行的任务添加到延迟队列中，然后由消费者线程从队列中取出延迟时间到期的任务进行执行。

以下是Java延迟队列的应用示例：

1. 创建延迟任务类，实现Delayed接口，重写getDelay方法和compareTo方法。任务类可以包含需要执行的任务逻辑。

public class DelayedTask implements Delayed {
    private String taskName;
    private long delayTime;

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

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

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

    public void executeTask() {
        // 执行任务逻辑
        System.out.println("Task " + taskName + " executed!");
    }
}

2. 创建延迟队列，并添加延迟任务。

DelayQueue<DelayedTask> delayQueue = new DelayQueue<>();

// 添加延迟任务
delayQueue.offer(new DelayedTask("Task1", 3000));
delayQueue.offer(new DelayedTask("Task2", 5000));
delayQueue.offer(new DelayedTask("Task3", 1000));

3. 创建消费者线程，从延迟队列中取出到期的任务并执行。

Thread consumerThread = new Thread(() -> {
    while (!Thread.currentThread().isInterrupted()) {
        try {
            DelayedTask task = delayQueue.take();
            task.executeTask();
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
});
consumerThread.start();

延迟队列会按照任务的延迟时间进行排序，到期时间越早的任务会排在队列的前面，消费者线程从队列中取出到期的任务进行执行。

以上就是Java延迟队列的应用示例，可以根据实际需求灵活运用延迟队列来实现定时任务调度等功能。