在Java中如何使用DelayQueue处理延迟任务_DelayQueue集合实践技巧

import java.util.concurrent.*;
<p>// 定义延迟任务
class DelayedTask implements Delayed {
private String message;
private long executeTime; // 执行时间戳（毫秒）</p><pre class='brush:java;toolbar:false;'>public DelayedTask(String message, long delayInMs) {
    this.message = message;
    this.executeTime = System.currentTimeMillis() + delayInMs;
}

@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, ((DelayedTask) other).executeTime);
}

@Override
public String toString() {
    return "DelayedTask{" +
            "message='" + message + '\'' +
            ", executeTime=" + executeTime +
            '}';
}

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

    // 启动消费者线程
    Thread consumer = new Thread(() -> {
        try {
            while (!Thread.interrupted()) {
                DelayedTask task = queue.take(); // 阻塞直到任务到期
                System.out.println("执行: " + task.message + 
                    " (当前时间: " + System.currentTimeMillis() + ")");
            }
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    });

    consumer.start();

    // 主线程等待一段时间后中断消费者
    try {
        Thread.sleep(6000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    consumer.interrupt();
}