Java DelayQueue线程同步的延迟队列

向右看齐 2024-01-20 07:22 55阅读 0赞

## Java DelayQueue线程同步的延迟队列 ##

import java.text.SimpleDateFormat;
    import java.util.Date;
    import java.util.concurrent.DelayQueue;
    import java.util.concurrent.Delayed;
    import java.util.concurrent.TimeUnit;
    
    /**
     * Java DelayQueue线程同步的延迟队列。
     * DelayQueue比较适合一些特定的需要延迟处理的线程同步操作任务。
     * 比如，典型的，一批缓存，有失效时间，在失效时间超过后就清除掉。
     * 传统的基本做法大体上是轮询判断失效时间。
     * DelayQueue提供了一种更简洁和直观的方案处理。如本例。
     */
    public class Main {
    
        public static void main(String[] args) {
            new Main().test();
        }
    
        private void test() {
            DelayQueue<DataCache> mQueue = new DelayQueue<>();
    
            // 创建一个DelayQueue。
            // 在DelayQueue里面存放10条有过期/失效时间的缓存数据。
            // 失效时间通过setExpireTime设置。
            for (int i = 0; i < 10; i++) {
                DataCache data = new DataCache();
                //缓存的具体内容。
                data.setMsg("缓存" + i);
    
                //给缓存时间设置缓存失效时间。
                data.setExpireTime(System.currentTimeMillis() + (i + 2) * 2000);
    
                //把缓存数据加入缓存队列。
                mQueue.offer(data);
            }
    
            //开始延迟处理缓存数据。当失效时候就清理掉。
            new Thread(new Runnable() {
                @Override
                public void run() {
                    while (true) {
                        if (mQueue.isEmpty()) {
                            break;
                        } else {
                            DataCache data;
                            try {
                                System.out.println("当前队列长度:" + mQueue.size());
    
                                data = mQueue.take(); //从队列中取出一条数据。
    
                                System.out.println(data.getMsg() + " 失效时间:\t" + timeUtil(data.getExpireTime()));
                                System.out.println("在系统时间\t\t" + timeUtil(System.currentTimeMillis()) + " 清除缓存");
                                System.out.println("==========");
                            } catch (Exception e) {
                                e.printStackTrace();
                            }
                        }
                    }
                }
            }).start();
        }
    
        //一个缓存的具体类。
        //包含缓存失效时间，以及失效内容。
        private class DataCache implements Delayed {
            private String msg = null;
    
            //缓存的失效时间。
            private long expireTime = 0;
    
            public String getMsg() {
                return msg;
            }
    
            public void setMsg(String msg) {
                this.msg = msg;
            }
    
            public void setExpireTime(long expireTime) {
                this.expireTime = expireTime;
            }
    
            public long getExpireTime() {
                return expireTime;
            }
    
            //返回的值≤0时才会出队（被take）。
            @Override
            public long getDelay(TimeUnit timeUnit) {
                return timeUnit.convert(this.getExpireTime() - System.currentTimeMillis(), TimeUnit.MILLISECONDS);
            }
    
            //该函数重写不当将导致待处理的队列数据积压。
            @Override
            public int compareTo(Delayed delayed) {
                int value = (int) (this.getDelay(TimeUnit.MILLISECONDS) - delayed.getDelay(TimeUnit.MILLISECONDS));
                return value;
            }
        }
    
        //把long型time时间转化为人类可读的字符串。
        private String timeUtil(long t) {
            SimpleDateFormat format = new SimpleDateFormat("mm分:ss秒:SS毫秒");
            Date date = new Date();
            date.setTime(t);
            return format.format(date);
        }
    }

输出：

当前队列长度:10
    缓存0 失效时间:	34分:22秒:297毫秒
    在系统时间		34分:22秒:343毫秒 清除缓存
    ==========
    当前队列长度:9
    缓存1 失效时间:	34分:24秒:297毫秒
    在系统时间		34分:24秒:312毫秒 清除缓存
    ==========
    当前队列长度:8
    缓存2 失效时间:	34分:26秒:297毫秒
    在系统时间		34分:26秒:311毫秒 清除缓存
    ==========
    当前队列长度:7
    缓存3 失效时间:	34分:28秒:297毫秒
    在系统时间		34分:28秒:311毫秒 清除缓存
    ==========
    当前队列长度:6
    缓存4 失效时间:	34分:30秒:297毫秒
    在系统时间		34分:30秒:310毫秒 清除缓存
    ==========
    当前队列长度:5
    缓存5 失效时间:	34分:32秒:297毫秒
    在系统时间		34分:32秒:310毫秒 清除缓存
    ==========
    当前队列长度:4
    缓存6 失效时间:	34分:34秒:297毫秒
    在系统时间		34分:34秒:309毫秒 清除缓存
    ==========
    当前队列长度:3
    缓存7 失效时间:	34分:36秒:297毫秒
    在系统时间		34分:36秒:309毫秒 清除缓存
    ==========
    当前队列长度:2
    缓存8 失效时间:	34分:38秒:297毫秒
    在系统时间		34分:38秒:308毫秒 清除缓存
    ==========
    当前队列长度:1
    缓存9 失效时间:	34分:40秒:297毫秒
    在系统时间		34分:40秒:308毫秒 清除缓存
    ==========