java DelayQueue 封装

封装 DelayQueue 可以提高代码的可读性和可维护性，并且可以使代码更加灵活。下面是一个基本的 Java DelayQueue 封装示例：

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

public class DelayQueueWrapper<T extends Delayed> {
    private final DelayQueue<T> queue = new DelayQueue<>();

    public void put(T element) {
        queue.put(element);
    }

    public T take() throws InterruptedException {
        return queue.take();
    }
}

这个封装类使用了泛型来支持不同类型的元素。在这个封装类中，我们只向外暴露了 put() 和 take() 两个方法，这样可以防止外部使用者对 DelayQueue 进行不当操作。

另外，由于 DelayQueue 的元素需要实现 Delayed 接口并提供 getDelay() 方法的实现，所以在使用这个封装类时，我们需要为泛型指定一个实现了 Delayed 接口的类或者接口来作为元素类型，例如：

public class MyTask implements Delayed {
    private long delayTime;
    private String taskName;

    public MyTask(long delayTime, String taskName) {
        this.delayTime = delayTime;
        this.taskName = taskName;
    }

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

    @Override
    public int compareTo(Delayed o) {
        if (this.delayTime < ((MyTask) o).delayTime) {
            return -1;
        } else if (this.delayTime > ((MyTask) o).delayTime) {
            return 1;
        }
        return 0;
    }
}

这个 MyTask 类实现了 Delayed 接口，并且提供了 getDelay() 和 compareTo() 方法的实现。这个封装类可以用来存储 MyTask 类型的任务，并且可以根据任务的延迟时间进行排序和获取。

使用这个封装类时，我们可以这样写：

DelayQueueWrapper<MyTask> delayQueueWrapper = new DelayQueueWrapper<>();
delayQueueWrapper.put(new MyTask(System.currentTimeMillis() + 1000, "Task1"));
MyTask task1 = delayQueueWrapper.take();

以上就是一个基本的 Java DelayQueue 封装示例，可以根据需求进行修改和扩展。