JAVA中的延迟队列DelayQueue应用解析

@Data
public class DelayTask implements Delayed {
    /**
     * 开始计时时间 不设置则默认为当前系统时间
     */
    private transient Date taskStartTime = new Date();
    /**
     * 过期时间 不设置则默认1分钟
     */
    private transient long taskExpiredTime = 60 * 1000;
    /**
     * 初始设置开始计时时间
     * taskStartTime 开始时间 [String] [yyyy-MM-dd HH:mm:ss]
     * taskExpiredTime 过期时间 [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;
    //私海线索过期时间：24h
    public static final long CLUE_EXPIRED_TIME = 24 * 60 * 60 * 1000;
    //私海客户过期时间：60天
    public static final long CUS_EXPIRED_TIME = 60L * 24 * 60 * 60 * 1000;
    //线索、客户释放后冷冻时间：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.将所有未到期的线程、客户入队
        //......
        //2.开启一个消费者线程
        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;
            //修改状态
          	clue.update();
        }
    }
}

 /**
     * 将线索\客户加入超时自动更新状态队列
     * @param clue 线索\客户对象
     * @param type 0：私海线索 1：私海客户 3：释放后元素
     * @param startTime 开始计时时间
     */
    public void addToTimeoutAutoUpdateQueue(Clue clue, int type, Date startTime) {
        long expireTime = 0;
        if(type == CLUE) { //线索队列
            expireTime = DelayQueueHelper.CLUE_EXPIRED_TIME;
        }else if(type == CUS) { //客户队列
            expireTime = DelayQueueHelper.CUS_EXPIRED_TIME;
        }else if(type == LOCK) { //冻结队列
            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);
    }
	/**
     * 将线索从超时自动更新状态队列中删除
     * @param clue
     */
    public void removeFromTimeoutAutoUpdateQueue(Clue clue) {
        DelayQueueHelper queueHelper = DelayQueueHelper.getInstance();
        queueHelper.removeTask(clue);
    }