《DelayQueue：Java界的“延时大师”》

文章目录

- - 1. DelayQueue的基本使用
  - 2. DelayQueue的应用场景
  - 3. 为什么选择DelayQueue？
  - 结语
  - 推荐阅读文章

今天我们要聊的是Java界的“延时大师”——DelayQueue。想象一下，你是一个时间管理大师，有些事情你不想立刻做，而是想在未来某个特定的时间点才去做。这时，DelayQueue就是你的时间机器，让你的任务在预定的时间自动执行。那么，如何使用这个时间机器，以及在什么场景下使用它呢？让我们一起来看看。

1. DelayQueue的基本使用

首先，我们得知道如何使用DelayQueue。这就像是学习如何驾驶时间机器。你需要有一个任务（对象），这个任务必须实现Delayed接口，这个接口让你的任务知道何时该被执行。

import java.util.concurrent.DelayQueue;
import java.util.concurrent.Delayed;
import java.util.concurrent.TimeUnit;

class DelayedTask implements Delayed {
    private long delayTime; // 延迟时间，单位纳秒
    private long expire; // 过期时间，即当前时间加上延迟时间

    public DelayedTask(long delay, String taskId) {
        this.delayTime = delay;
        this.expire = System.nanoTime() + TimeUnit.MILLISECONDS.toNanos(delay);
    }

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

    @Override
    public int compareTo(Delayed other) {
        if (other == this) {
            return 0;
        }
        long diff = getDelay(TimeUnit.NANOSECONDS) - other.getDelay(TimeUnit.NANOSECONDS);
        return (diff < 0) ? -1 : (diff > 0) ? 1 : 0;
    }

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

public class DelayQueueExample {
    public static void main(String[] args) throws InterruptedException {
        // 创建一个延迟队列
        DelayQueue<DelayedTask> delayQueue = new DelayQueue<>();
        delayQueue.put(new DelayedTask(1, "Task 1")); // 1秒后执行
        delayQueue.put(new DelayedTask(3, "Task 2")); // 3秒后执行

        // 取出并执行任务
        while (!delayQueue.isEmpty()) {
            DelayedTask task = delayQueue.take();
            System.out.println("Executing task: " + task);
        }
    }
}