Java的延迟队列之DelayQueue解读

public class DelayQueue<E extends Delayed> extends AbstractQueue<E> implements BlockingQueue<E>

public class OrderDelayTask implements Delayed {
    
    private Long orderId;
    
    private long delayTime;

    public OrderDelayTask(Long orderId, long delayTime) {
        this.orderId = orderId;
        // 延迟时间加当前时间
        this.delayTime = System.currentTimeMillis() + delayTime;
    }

    // 获取任务剩余时间
    @Override
    public long getDelay(TimeUnit unit) {
        return unit.convert(delayTime - System.currentTimeMillis(), TimeUnit.MILLISECONDS);
    }

    @Override
    public int compareTo(Delayed o) {
        return Long.compare(delayTime, ((OrderDelayTask) o).delayTime);
    }
}

@Bean("orderDelayQueue")
public DelayQueue<OrderDelayTask> orderDelayQueue(){
    return new DelayQueue<OrderDelayTask>();
}

@Autowired
private DelayQueue<OrderDelayObject> orderDelayQueue;

//发起订单下单的时候将订单演示对象放入orderDelayQueue
orderDelayQueue.add(
        new OrderDelayTask(
                "123456", // 订单id
                30 * 60 * 1000, // 延迟时间：30分钟
        )
);

@Component
public class DelayTaskRunner<OrderDelayTask> implements InitializingBean {
    
    @Autowired
    private DelayQueue<OrderDelayTask> orderDelayQueue;
    
    @Override
    public void afterPropertiesSet() throws Exception {
    	new Thread(() -> {
            try {
                while(true) {
                    OrderDelayTask task = orderDelayQueue.take();
                    // 当队列为null的时候，poll()方法会直接返回null, 不会抛出异常，但是take()方法会一直等待，因此会抛出一个InterruptedException类型的异常。(当阻塞方法收到中断请求的时候就会抛出InterruptedException异常)
                    Long orderId = task.getOrderId();
                    // 执行业务
                }
            } catch (InterruptedException e) { 
                // 因为是重写Runnable接口的run方法，子类抛出的异常要小于等于父类的异常。而在Runnable中run方法是没有抛异常的。所以此时是不能抛出InterruptedException异常。如果此时你只是记录日志的话，那么就是一个不负责任的做法，因为在捕获InterruptedException异常的时候自动的将是否请求中断标志置为了false。在捕获了InterruptedException异常之后，如果你什么也不想做，那么就将标志重新置为true，以便栈中更高层的代码能知道中断，并且对中断作出响应。
            	Thread.currentThread().interrupt();
            }
        }).start();
    }
}