問(wèn)題描述

我使用java的延遲隊(duì)列來(lái)取數(shù)據(jù)，但是發(fā)現(xiàn)根本無(wú)法取出數(shù)據(jù)。

package com.test;import java.util.concurrent.Delayed;import java.util.concurrent.TimeUnit;public class SmsEntity implements Delayed { private final long WAIT_TIME = 10; private long startTime = System.currentTimeMillis(); private String phone; public SmsEntity(String phone) {this.phone = phone; } public String getPhone() {return phone; } public void setPhone(String phone) {this.phone = phone; } public long getStartTime() {return startTime; } public void setStartTime(long startTime) {this.startTime = startTime; } @Override public int compareTo(Delayed o) {SmsEntity entity = (SmsEntity) o;if (this.getStartTime() - entity.getStartTime() > 0) { return 1;}return -1; } @Override public long getDelay(TimeUnit unit) {//long waitTimeForGiveTimeUnit = unit.convert(WAIT_TIME, TimeUnit.MILLISECONDS);//long areadyLeftTime = unit.convert(System.currentTimeMillis(), TimeUnit.MILLISECONDS)//- unit.convert(startTime, TimeUnit.MILLISECONDS);//if (areadyLeftTime > waitTimeForGiveTimeUnit) {// return 0;//}//return unit.convert(waitTimeForGiveTimeUnit - areadyLeftTime, TimeUnit.MILLISECONDS);return 1; }}package com.test;import java.util.concurrent.DelayQueue;public class DelayQueueDemo { public static void main(String[] args) {DelayQueue<SmsEntity> queue=new DelayQueue<>();queue.put(new SmsEntity('1'));try {// Thread.sleep(3000); queue.put(new SmsEntity('2')); System.out.println(queue.take().getPhone()); System.out.println(queue.take().getPhone());} catch (InterruptedException e) { e.printStackTrace();} }}

結(jié)果是一直在阻塞。我想請(qǐng)教這是為什么，感覺(jué)自己調(diào)用的沒(méi)有錯(cuò)啊

問(wèn)題解答

getDelay()始終返回1，所以永遠(yuǎn)不會(huì)expire。

可以仔細(xì)研究一下DelayQueue的文檔： https://docs.oracle.com/javas...

Expiration occurs when an element’s getDelay(TimeUnit.NANOSECONDS)method returns a value less than or equal to zero