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

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