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

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

P粉602998670

发布： 2025-10-14 08:58:01

原创

576人浏览过

DelayQueue是Java中用于延迟任务调度的无界阻塞队列，元素需实现Delayed接口并按延迟时间排序，适合定时任务、缓存过期等场景。

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

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

1. DelayQueue 和 Delayed 接口简介

要使用 DelayQueue，队列中的元素必须实现 Delayed 接口，该接口继承自 Comparable，并定义了两个方法：

getDelay(TimeUnit unit)：返回当前对象还需要延迟的时间。
compareTo(Delayed other)：用于排序，决定元素在队列中的优先级（延迟时间短的排在前面）。

2. 自定义延迟任务

下面是一个简单的延迟任务类，表示一个带执行时间的消息：

import java.util.concurrent.Delayed;
import java.util.concurrent.TimeUnit;
<p>public class DelayedMessage implements Delayed {
private String message;
private long executeTime; // 执行时间戳（毫秒）</p><pre class='brush:java;toolbar:false;'>public DelayedMessage(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, ((DelayedMessage) other).executeTime);
}

public String getMessage() {
    return message;
}

登录后复制

}

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

3. 使用 DelayQueue 实现延迟消费

创建一个 DelayQueue 并添加延迟任务，消费者线程通过 take() 方法获取已到期的任务：

如知AI笔记

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

查看详情

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

    System.out.println("等待任务执行...");

    // 消费者线程
    while (!queue.isEmpty()) {
        try {
            DelayedMessage msg = queue.take(); // 阻塞直到有任务到期
            System.out.println("处理消息: " + msg.getMessage() +
                    "，当前时间: " + System.currentTimeMillis());
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            break;
        }
    }
}

登录后复制

}

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

输出顺序会按照延迟时间由短到长执行，即使插入顺序不同，也能保证先到期的任务先被处理。