如何在Java中实现延迟队列DelayQueue-java教程-PHP中文网

如何在Java中实现延迟队列DelayQueue

P粉602998670

发布： 2025-10-14 16:28:01

原创

821人浏览过

DelayQueue是Java中基于优先级队列实现的无界阻塞队列，用于存放实现Delayed接口的对象，只有当对象的延迟时间到达后才能被取出，适用于定时任务、缓存过期等场景。

如何在java中实现延迟队列delayqueue

在Java中，DelayQueue 是一个无界阻塞队列，它用于存放实现了 Delayed 接口的对象。只有当对象的延迟时间到达后，才能从队列中取出。这个特性非常适合实现定时任务、缓存过期、消息延迟处理等场景。

DelayQueue 的基本原理

DelayQueue 要求队列中的元素必须实现 java.util.concurrent.Delayed 接口。该接口有两个方法：

getDelay(TimeUnit unit)：返回当前对象还需要延迟的时间。
compareTo(Delayed other)：用于排序，决定谁先出队。

DelayQueue 内部基于优先级队列（PriorityQueue）实现，元素按延迟时间排序，延迟最短的排在队首。

实现自定义延迟任务

要使用 DelayQueue，需要创建一个类实现 Delayed 接口。以下是一个简单的示例：

立即学习“Java免费学习笔记（深入）”；

import java.util.concurrent.Delayed;
import java.util.concurrent.TimeUnit;
<p>public class DelayTask implements Delayed {
private String message;
private long executeTime; // 执行时间戳（毫秒）</p><pre class='brush:java;toolbar:false;'>public DelayTask(String message, long delayInMilliseconds) {
    this.message = message;
    this.executeTime = System.currentTimeMillis() + delayInMilliseconds;
}

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

@Override
public int compareTo(Delayed other) {
    return Long.compare(this.executeTime, ((DelayTask) other).executeTime);
}

public String getMessage() {
    return message;
}

登录后复制

}

如知AI笔记

如知笔记——支持markdown的在线笔记，支持ai智能写作、AI搜索，支持DeepseekR1满血大模型

查看详情

使用 DelayQueue 处理延迟任务

下面演示如何向 DelayQueue 添加任务，并由消费者线程取出执行：

import java.util.concurrent.*;
<p>public class DelayQueueExample {
public static void main(String[] args) {
DelayQueue<DelayTask> queue = new DelayQueue<>();</p><pre class='brush:java;toolbar:false;'>    // 添加几个延迟任务
    queue.put(new DelayTask("任务1 - 5秒后执行", 5000));
    queue.put(new DelayTask("任务2 - 3秒后执行", 3000));
    queue.put(new DelayTask("任务3 - 8秒后执行", 8000));

    System.out.println("任务已提交");

    // 消费者线程处理任务
    while (!queue.isEmpty()) {
        try {
            DelayTask task = queue.take(); // take() 会阻塞直到有任务到期
            System.out.println("执行: " + task.getMessage());
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            break;
        }
    }
}

登录后复制

}

输出结果会按照延迟时间顺序打印，即使任务不是按顺序添加的。