java DelayQueue

刺骨的言语ヽ痛彻心扉 2022-06-01 10:41 157阅读 0赞

import java.util.Date;
    import java.util.concurrent.DelayQueue;
    import java.util.concurrent.Delayed;
    import java.util.concurrent.TimeUnit;
    
    class DelayObj implements Delayed {
    
        private long delayTime;
        private long expire;
        private String data;
    
        public DelayObj(int delayTime, String data) {
            this.data = data;
            delayTime = delayTime;
            expire += System.currentTimeMillis() + delayTime;
        }
    
        @Override
        public long getDelay(TimeUnit unit) {
            return unit.convert(expire - System.currentTimeMillis(), TimeUnit.SECONDS);
        }
    
        @Override
        public int compareTo(Delayed o) {
            return (int) (getDelay(TimeUnit.SECONDS) - o.getDelay(TimeUnit.SECONDS));
        }
    
        public void sayHello() {
            System.out.println("在这个时刻:" + new Date().toLocaleString() + "被执行===>" + data);
        }
    }
    
    public class MyDelayQueueTest {
        public static void main(String[] args) throws InterruptedException {
            DelayQueue<DelayObj> delayQueue = new DelayQueue<>();
    
            DelayObj wumiaozhongDelay = new DelayObj(5,"五秒钟后执行的线程");
            DelayObj shimiaozhongDelay = new DelayObj(10,"十秒钟后执行的线程");
    
            delayQueue.offer(wumiaozhongDelay);
            delayQueue.offer(shimiaozhongDelay);
    
            DelayObj result = delayQueue.take();
            result.sayHello();
            result = delayQueue.take();
            result.sayHello();
    
            System.out.println("证明队列里的东西被取光之前,是阻塞的");
    
    
    
    
    
        }
    }

发表评论取消回复

表情：

评论列表（有 0 条评论，157人围观）

还没有评论，来说两句吧...

相关阅读

相关 Java延迟队列——DelayQueue

Java延迟队列——DelayQueue DelayQueue的定义 public class DelayQueue<E extends Delaye

蔚落/ 2024年02月23日 03:18/ 0 赞/ 17 阅读

相关 DelayQueue

`DelayQueue` 是一个线程安全的队列实现，它继承自 `java.util.concurrent.Delayed` 接口，用于存储元素并按照元素的过期时间进行排序。`

Bertha 。/ 2023年10月16日 13:57/ 0 赞/ 23 阅读

相关 DelayQueue讲解

DelayQueue讲解 DelayQueue 是一个带延时功能的阻塞队列，可以通过它轻松的实现定时任务、延时任务，比如重试、异步提醒、定时通知等等。那DelayQ

快来打我*/ 2023年06月03日 14:53/ 0 赞/ 6 阅读

相关 DelayQueue浮光掠影

现在是2020年8月，正式从大学毕业也已经第三个年头了，现在想想还是挺快。通过最近这段时间对公司项目的改造，在使用spring cloud、spring cloud kub

深碍√TFBOYSˉ_/ 2022年11月25日 05:25/ 0 赞/ 115 阅读

相关 PriorityBlockingQueue和DelayQueue

PriorityBlockingQueue PriorityQueue（优先级阻塞队列）是按照元素的优先级从小到大出队列的。正因为如此， PriorityQueue元素之

阳光穿透心脏的1/2处/ 2022年09月03日 05:19/ 0 赞/ 125 阅读

相关 java DelayQueue

import java.util.Date; import java.util.concurrent.DelayQueue; import java.u

刺骨的言语ヽ痛彻心扉/ 2022年06月01日 10:41/ 0 赞/ 158 阅读

相关 java DelayQueue 关联redis

关联redis的DelayQueue java 的延时队列相信很多人都用过，因为这东西应用场景太多了，但是有一点，就是如果重启服务器，那么延时队列里的东西都没了，特

客官°小女子只卖身不卖艺/ 2022年05月10日 01:34/ 0 赞/ 137 阅读

相关 java 之DelayQueue实际运用示例

[java 之DelayQueue实际运用示例][java _DelayQueue] 在学习Java 多线程并发开发过程中，了解到DelayQueue类的主要作用：是一个

梦里梦外;/ 2022年03月21日 13:56/ 0 赞/ 279 阅读

相关 DelayQueue用例

DelayQueue是一个延迟队列，插入队列的数据只有达到设置的延迟时间时才能被取出，否则线程会被阻塞。插入队列的对象必须实现Delayed接口，实现comapreTo方法和g

淡淡的烟草味﹌/ 2022年02月24日 21:14/ 0 赞/ 181 阅读

相关 java并发队列之DelayQueue

[为什么80%的码农都做不了架构师？>>> ][80_] ![hot3.png][] 特点：无界队列，阻塞队列，具有延时性。用于存放实现了Delayed接口的对象，其中的对

Bertha 。/ 2022年01月15日 04:47/ 0 赞/ 230 阅读