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;
        // 延遲時(shí)間加當(dāng)前時(shí)間
        this.delayTime = System.currentTimeMillis() + delayTime;
    }

    // 獲取任務(wù)剩余時(shí)間
    @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;

//發(fā)起訂單下單的時(shí)候?qū)⒂唵窝菔緦ο蠓湃雘rderDelayQueue
orderDelayQueue.add(
        new OrderDelayTask(
                "123456", // 訂單id
                30 * 60 * 1000, // 延遲時(shí)間：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();
                    // 當(dāng)隊(duì)列為null的時(shí)候，poll()方法會(huì)直接返回null, 不會(huì)拋出異常，但是take()方法會(huì)一直等待，因此會(huì)拋出一個(gè)InterruptedException類型的異常。(當(dāng)阻塞方法收到中斷請求的時(shí)候就會(huì)拋出InterruptedException異常)
                    Long orderId = task.getOrderId();
                    // 執(zhí)行業(yè)務(wù)
                }
            } catch (InterruptedException e) { 
                // 因?yàn)槭侵貙慠unnable接口的run方法，子類拋出的異常要小于等于父類的異常。而在Runnable中run方法是沒有拋異常的。所以此時(shí)是不能拋出InterruptedException異常。如果此時(shí)你只是記錄日志的話，那么就是一個(gè)不負(fù)責(zé)任的做法，因?yàn)樵诓东@InterruptedException異常的時(shí)候自動(dòng)的將是否請求中斷標(biāo)志置為了false。在捕獲了InterruptedException異常之后，如果你什么也不想做，那么就將標(biāo)志重新置為true，以便棧中更高層的代碼能知道中斷，并且對中斷作出響應(yīng)。
            	Thread.currentThread().interrupt();
            }
        }).start();
    }
}