Java多线程并发开发之DelayQueue使用示例
在学习Java多线程并发开发过程中，了解到DelayQueue类的主要作用：是一个无界的BlockingQueue，用于放置实现了Delayed接口的对象，其中的对象只能在其到期时才能从队列中取走。这种队列是有序的，即队头对象的延迟到期时间最长。注意：不能将null元素放置到这种队列中。
Delayed，一种混合风格的接口，用来标记那些应该在给定延迟时间之后执行的对象。此接口的实现必须定义一个compareTo方法，该方法提供与此接口的getDelay方法一致的排序。
在网上看到了一些示例，发现有的示例存在一些问题，做了些修改，希望能帮助大家理解。
中国人都喜欢K歌，大部分人的内心都住着一个歌手的梦，尤其是学生时代，大家都喜欢组团去KTV唱歌，一唱一下午，大家都唱得很爽。话说又到了一年一度的双11，许多的单身狗开始组团来到KTV唱歌。那么KTV这个时候如何通过程序来收费记时的呢，模拟的代码如下：
publicclassKTVimplementsRunnable{
privateDelayQueuequeue=newDelayQueue<>();
publicvoidbegin(Stringname,StringboxNum,intmoney){
KTVConsumerman=newKTVConsumer(name,boxNum,20l*money+System.currentTimeMillis());
System.out.println(man.getName()+"等人交了"+money+"元钱，进入"+man.getBoxNum()+"号包厢,开始K歌...");
this.queue.add(man);
}
publicvoidend(KTVConsumerman){
System.out.println(man.getName()+"等人所在的"+man.getBoxNum()+"号包厢,时间到...");
}
@Override
publicvoidrun(){
//TODOAuto-generatedmethodstub
while(true){
try{
KTVConsumerman=queue.take();
end(man);
}catch(InterruptedExceptione){
//TODOAuto-generatedcatchblock
e.printStackTrace();
}
}
}
publicstaticvoidmain(Stringargs[]){
try{
System.out.println("KTV正常营业");
System.out.println("================================");
KTVktv=newKTV();
Threadsing=newThread(ktv);
sing.start();
newThread(newRunnable(){
@Override
publicvoidrun(){
ktv.begin("张三","111",500);
}
}).start();
newThread(newRunnable(){
@Override
publicvoidrun(){
ktv.begin("李四","666",200);
}
}).start();
Thread.sleep(2000);
newThread(newRunnable(){
@Override
publicvoidrun(){
ktv.begin("王五","888",100);
System.out.println("================================");
}
}).start();
}
catch(Exceptionex){
}
}
}
publicclassKTVConsumerimplementsDelayed{
privateStringname;
//截止时间
privatelongendTime;
//包厢号
privateStringboxNum;
publicKTVConsumer(Stringname,StringboxNum,longendTime){
this.name=name;
this.boxNum=boxNum;
this.endTime=endTime;
}
publicStringgetName(){
returnthis.name;
}
publicStringgetBoxNum(){
returnthis.boxNum;
}
/**
*用来判断是否到了截止时间
*/
@Override
publiclonggetDelay(TimeUnitunit){
//TODOAuto-generatedmethodstub
returnunit.convert(endTime-System.currentTimeMillis(),TimeUnit.MILLISECONDS);
}
/**
*相互比较排序用
*/
@Override
publicintcompareTo(Delayedo){
//TODOAuto-generatedmethodstub
if(o==null||!(oinstanceofKTVConsumer))return1;
if(o==this)return0;
KTVConsumers=(KTVConsumer)o;
returnendTime-s.endTime>0?1:(endTime-s.endTime==0?0:-1);
}
}
运行的结果如下：
KTV正常营业 ================================ 张三等人交了500元钱，进入111号包厢,开始K歌... 李四等人交了200元钱，进入666号包厢,开始K歌... 王五等人交了100元钱，进入888号包厢,开始K歌... ================================ 李四等人所在的666号包厢,时间到... 王五等人所在的888号包厢,时间到... 张三等人所在的111号包厢,时间到...
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。