spring中的延时队列

Spring中的延时队列可以通过使用`DelayQueue`来实现。`DelayQueue`是一个支持延时获取元素的无界阻塞队列，其中的元素必须实现`Delayed`接口。`Delayed`接口中定义了`getDelay()`方法，用于获取元素的延迟时间。`DelayQueue`会根据元素的延迟时间来决定元素的顺序，延迟时间最短的元素将被最先获取。

在Spring中，可以使用`@Scheduled`注解来定时执行任务。结合`DelayQueue`，可以实现延时执行任务的功能。具体实现步骤如下：

1. 定义一个实现`Delayed`接口的任务类，其中需要实现`getDelay()`方法来返回任务的延迟时间。

2. 创建一个`DelayQueue`队列，并将任务添加到队列中。

3. 创建一个定时任务，每隔一段时间从队列中取出延迟时间已到的任务并执行。

下面是一个简单的示例代码：

@Component
public class DelayedTask implements Delayed {
    private String name;
    private long executeTime;

    public DelayedTask(String name, long delay) {
        this.name = name;
        this.executeTime = System.currentTimeMillis() + delay;
    }

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

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

    public void execute() {
        System.out.println("Task " + name + " executed at " + new Date());
    }
}

@Component
public class DelayedTaskExecutor {
    private DelayQueue<DelayedTask> taskQueue = new DelayQueue<>();

    // 添加延时任务
    public void addTask(DelayedTask task) {
        taskQueue.put(task);
    }

    // 定时执行任务
    @Scheduled(fixedDelay = 1000)
    public void executeTask() {
        DelayedTask task = taskQueue.poll();
        while (task != null) {
            task.execute();
            task = taskQueue.poll();
        }
    }
}

// 测试
@Autowired
private DelayedTaskExecutor executor;

public void test() {
    DelayedTask task1 = new DelayedTask("task1", 5000);
    DelayedTask task2 = new DelayedTask("task2", 8000);
    executor.addTask(task1);
    executor.addTask(task2);
}

在上面的示例中，`DelayedTask`类表示一个延时任务，`DelayedTaskExecutor`类用于管理延时任务队列并定时执行任务。在`test()`方法中，创建两个延时任务并添加到队列中，经过一段时间后，这两个任务将被定时执行。