java延迟队列怎么实现 - 问答

Java中的延迟队列可以通过使用DelayQueue类来实现。DelayQueue是一个无界阻塞队列，其中的元素按照指定的延迟时间进行排序。只有延迟期满的元素才能从队列中取出。

要实现延迟队列，首先需要定义一个实现了Delayed接口的类，该接口要求实现两个方法：getDelay()和compareTo()。

定义延迟元素类：

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

public class DelayedElement implements Delayed {
    private String data;
    private long expireTime;

    public DelayedElement(String data, long delayTime) {
        this.data = data;
        this.expireTime = System.currentTimeMillis() + delayTime;
    }

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

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

    public String getData() {
        return data;
    }
}

创建延迟队列并添加延迟元素：

import java.util.concurrent.DelayQueue;

public class Main {
    public static void main(String[] args) throws InterruptedException {
        DelayQueue<DelayedElement> delayQueue = new DelayQueue<>();

        // 添加延迟元素
        delayQueue.offer(new DelayedElement("Element 1", 2000));
        delayQueue.offer(new DelayedElement("Element 2", 5000));
        delayQueue.offer(new DelayedElement("Element 3", 3000));

        // 遍历获取延迟元素
        while (!delayQueue.isEmpty()) {
            DelayedElement element = delayQueue.take();
            System.out.println(element.getData());
        }
    }
}

以上代码创建了一个DelayQueue对象，并向队列中添加了3个延迟元素，分别设置了不同的延迟时间。然后通过take()方法从队列中取出元素，并打印其数据。

注意：take()方法是一个阻塞方法，如果队列中没有元素会一直等待，直到有元素被添加进来。如果想要非阻塞地获取元素，可以使用poll()方法。

这样就实现了一个简单的延迟队列。

0 赞

0 踩