@Data
public class DelayTask implements Delayed {
    /**
     * 開(kāi)始計(jì)時(shí)時(shí)間 不設(shè)置則默認(rèn)為當(dāng)前系統(tǒng)時(shí)間
     */
    private transient Date taskStartTime = new Date();
    /**
     * 過(guò)期時(shí)間 不設(shè)置則默認(rèn)1分鐘
     */
    private transient long taskExpiredTime = 60 * 1000;
    /**
     * 初始設(shè)置開(kāi)始計(jì)時(shí)時(shí)間
     * taskStartTime 開(kāi)始時(shí)間 [String] [yyyy-MM-dd HH:mm:ss]
     * taskExpiredTime 過(guò)期時(shí)間 [long] 單位：s
     * @param taskStartTime
     * @param taskExpiredTime
     */
    public void initTaskTime(String taskStartTime, long taskExpiredTime) {
        if(Assert.notEmpty(taskStartTime)) {
            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            try {
                this.taskStartTime = sdf.parse(taskStartTime);
            } catch (ParseException e) {
                e.printStackTrace();
            }
        }
        this.taskExpiredTime = taskExpiredTime;
        this.taskExpiredTime += this.taskStartTime.getTime();
    }
    @Override
    public long getDelay(TimeUnit unit) {
        return unit.convert(taskExpiredTime - System.currentTimeMillis(), TimeUnit.MILLISECONDS);
    }
    @Override
    public int compareTo(Delayed o) {
        return (this.getDelay(TimeUnit.MILLISECONDS) - ((DelayTask) o).getDelay(TimeUnit.MILLISECONDS)) > 0 ? 1:0;
    }
}

public class DelayQueueHelper {
    private volatile static DelayQueueHelper delayQueueHelper = null;
    //私海線索過(guò)期時(shí)間：24h
    public static final long CLUE_EXPIRED_TIME = 24 * 60 * 60 * 1000;
    //私?？蛻暨^(guò)期時(shí)間：60天
    public static final long CUS_EXPIRED_TIME = 60L * 24 * 60 * 60 * 1000;
    //線索、客戶釋放后冷凍時(shí)間：48h
    public static final long BLOCK_TIME = 48 * 60 * 60 * 1000;
    private DelayQueue<DelayTask> queue = new DelayQueue<>();
    private DelayQueueHelper() {
    }
    public static DelayQueueHelper getInstance() {
        if(delayQueueHelper == null) {
            synchronized(DelayQueueHelper.class) {
                delayQueueHelper = new DelayQueueHelper();
            }
        }
        return delayQueueHelper;
    }
    public void addTask(DelayTask task) {
        queue.put(task);
    }
    public void removeTask(DelayTask task) {
        if(task == null){
            return;
        }
        for(Iterator<DelayTask> iterator = queue.iterator(); iterator.hasNext();) {
            if(task instanceof Clue) {
                Clue clue = (Clue) task;
                Clue queueObj = (Clue) iterator.next();
                if(clue.getId().equals(queueObj.getId())){
                    queue.remove(queueObj);
                }
            }
        }
    }
    public DelayQueue<DelayTask> getQueue() {
        return queue;
    }
}

@Slf4j
@Component
public class DelayQueueRunner implements ApplicationRunner {
    @Override
    public void run(ApplicationArguments args) throws Exception {
        DelayQueueHelper queueHelper = DelayQueueHelper.getInstance();
        //1.將所有未到期的線程、客戶入隊(duì)
        //......
        //2.開(kāi)啟一個(gè)消費(fèi)者線程
        run(queueHelper.getQueue());
    }
    public void run(DelayQueue queue) {
        new Thread() {
            @Override
            public void run() {
                try {
                    while (true) {
                        DelayTask task = (DelayTask) queue.take();
                        executeTask(task);
                    }
                } catch (InterruptedException e) {
                    log.error(e.getMessage());
                    e.printStackTrace();
                }
            }
        }.start();
    }
    private void executeTask(DelayTask task) {
        if(task instanceof Clue) {
            Clue clue = (Clue) task;
            //修改狀態(tài)
          	clue.update();
        }
    }
}

 /**
     * 將線索\客戶加入超時(shí)自動(dòng)更新?tīng)顟B(tài)隊(duì)列
     * @param clue 線索\客戶對(duì)象
     * @param type 0：私海線索 1：私?？蛻?3：釋放后元素
     * @param startTime 開(kāi)始計(jì)時(shí)時(shí)間
     */
    public void addToTimeoutAutoUpdateQueue(Clue clue, int type, Date startTime) {
        long expireTime = 0;
        if(type == CLUE) { //線索隊(duì)列
            expireTime = DelayQueueHelper.CLUE_EXPIRED_TIME;
        }else if(type == CUS) { //客戶隊(duì)列
            expireTime = DelayQueueHelper.CUS_EXPIRED_TIME;
        }else if(type == LOCK) { //凍結(jié)隊(duì)列
            expireTime = DelayQueueHelper.BLOCK_TIME;
        }
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        DelayQueueHelper queueHelper = DelayQueueHelper.getInstance();
        clue.initTaskTime(sdf.format(startTime), expireTime);
        queueHelper.addTask(clue);
    }
	/**
     * 將線索從超時(shí)自動(dòng)更新?tīng)顟B(tài)隊(duì)列中刪除
     * @param clue
     */
    public void removeFromTimeoutAutoUpdateQueue(Clue clue) {
        DelayQueueHelper queueHelper = DelayQueueHelper.getInstance();
        queueHelper.removeTask(clue);
    }