java延时队列DelayQueue

public class DelayTaskEntity {
    /** 1活动开启 2活动关闭 */
    private Integer type;


    private String data;


    public DelayTaskEntity(Integer type, String data) {
        this.type = type;
        this.data = data;
    }


    public Integer getType() {
        return type;
    }


    public void setType(Integer type) {
        this.type = type;
    }


    public String getData() {
        return data;
    }


    public void setData(String data) {
        this.data = data;
    }


    @Override
    public int hashCode() {
        return super.hashCode();
    }


    @Override
    public boolean equals(Object obj) {
        if(obj instanceof DelayTaskEntity){
            DelayTaskEntity entity = (DelayTaskEntity)obj;
            return this.getData().equals(entity.getData()) && this.getType().equals(entity.getType());
        }


        return false;
    }
}

import java.util.concurrent.Delayed;
import java.util.concurrent.TimeUnit;


/**
* @author wjc
*/
public class DelayTask implements Delayed {


    private long time;
    private DelayTaskEntity param;


    public DelayTask(DelayTaskEntity param, long time) {
        this.param = param;
        this.time = time;
    }


    @Override
    public long getDelay(TimeUnit unit) {
        return unit.convert(time,TimeUnit.NANOSECONDS) - unit.convert(System.currentTimeMillis(),TimeUnit.NANOSECONDS);
    }


    @Override
    public int compareTo(Delayed o) {
        DelayTask item = (DelayTask) o;
        long diff = this.time - item.time;
        if (diff <= 0) {
            return -1;
        }else {
            return 1;
        }
    }


    public long getTime() {
        return time;
    }


    public void setTime(long time) {
        this.time = time;
    }


    public DelayTaskEntity getParam() {
        return param;
    }


    public void setParam(DelayTaskEntity param) {
        this.param = param;
    }


    @Override
    public boolean equals(Object obj) {
        if(obj instanceof DelayTask){
            DelayTask task = (DelayTask) obj;
            return this.getParam().equals(task.getParam());
        }
        return false;
    }


    @Override
    public int hashCode() {
        return super.hashCode();
    }
}

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;


import javax.annotation.PostConstruct;
import java.util.concurrent.DelayQueue;
import java.util.concurrent.Executors;


/**
* @author wjc
*/
@Component
public class DelayQueueUtil {


    @Autowired
    private DelayQueueService service;


    public static DelayQueue<DelayTask> queue = new DelayQueue<>();


    public static void add(DelayTask delayTask){
        queue.add(delayTask);
    }


    public static void remove(DelayTask delayTask){
        queue.remove(delayTask);
    }


    @PostConstruct
    public void init(){
        Executors.newFixedThreadPool(1).execute(new Thread(this::run));
    }


    private void run(){
        while (true){
            try{
                DelayTask task = queue.take();
                service.work(task.getParam());
            }catch (Exception e){
                e.printStackTrace();
            }
        }
    }


}