DelayQueue理解

public class DelayedBean implements Delayed {
    private long startTimeMills;

    private long delayMills;

    public DelayedBean(long startTimeMills, long delayMills) {
        this.startTimeMills = startTimeMills;
        this.delayMills = delayMills;
    }

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

    @Override
    public int compareTo(Delayed object) {
        DelayedBean descObject = (DelayedBean) object;
        return (int)Long.compare(this.getDelay(TimeUnit.MILLISECONDS),descObject.getDelay(TimeUnit.MILLISECONDS));
    }

    @Override
    public String toString() {
        return "DelayedBean{" +
                "startTimeMills=" + startTimeMills +
                ", delayMills=" + delayMills +
                ‘}‘;
    }

    public static void main(String[] args) throws InterruptedException {
        DelayQueue<DelayedBean> delayQueue = new DelayQueue<>();
        delayQueue.offer(new DelayedBean(System.currentTimeMillis(),1000));
        delayQueue.offer(new DelayedBean(System.currentTimeMillis(),2000));
        Thread.sleep(1000);
        System.out.println("first get from delayqueue="+delayQueue.poll());
        System.out.println("second get from delayqueue="+delayQueue.poll());
    }
}