星空网 > 软件开发 > Java

DelayQueue使用示例之KTV包厢记时

在学习Java线程并发开发过程中,了解到DelayQueue类的主要作用:是一个无界的BlockingQueue,用于放置实现了Delayed接口的对象,其中的对象只能在其到期时才能从队列中取走。这种队列是有序的,即队头对象的延迟到期时间最长。注意:不能将null元素放置到这种队列中。

Delayed,一种混合风格的接口,用来标记那些应该在给定延迟时间之后执行的对象。此接口的实现必须定义一个 compareTo 方法,该方法提供与此接口的 getDelay 方法一致的排序

在网上看到了一些示例,发现有的示例存在一些问题,做了些修改,希望能帮助大家理解。

中国人都喜欢K歌,大部分人的内心都住着一个歌手的梦,尤其是学生时代,大家都喜欢组团去KTV唱歌,一唱一下午,大家都唱得很爽。话说又到了一年一度的双11,许多的单身狗开始组团来到KTV唱歌。那么KTV这个时候如何通过程序来收费记时的呢,模拟的代码如下:

public class KTV implements Runnable{ private DelayQueue<KTVConsumer> queue = new DelayQueue<>(); public void begin(String name,String boxNum,int money){  KTVConsumer man = new KTVConsumer(name,boxNum,20l*money+System.currentTimeMillis());  System.out.println(man.getName()+" 等人交了"+money+"元钱,进入"+man.getBoxNum()+"号包厢,开始K歌...");  this.queue.add(man); } public void end(KTVConsumer man){  System.out.println(man.getName()+" 等人所在的"+man.getBoxNum()+"号包厢,时间到..."); } @Override public void run() {  // TODO Auto-generated method stub  while(true){   try {    KTVConsumer man = queue.take();    end(man);   } catch (InterruptedException e) {    // TODO Auto-generated catch block    e.printStackTrace();   }  } } public static void main(String args[]){  try{   System.out.println("KTV正常营业");   System.out.println("================================");   KTV ktv = new KTV();   Thread sing = new Thread(ktv);   sing.start();   new Thread(new Runnable() {    @Override    public void run() {     ktv.begin("张三", "111", 500);    }   }).start();   new Thread(new Runnable() {    @Override    public void run() {     ktv.begin("李四", "666", 200);    }   }).start();   Thread.sleep(2000);   new Thread(new Runnable() {    @Override    public void run() {     ktv.begin("王五", "888", 100);     System.out.println("================================");    }   }).start();  }  catch(Exception ex){  } }}public class KTVConsumer implements Delayed{ private String name; //截止时间 private long endTime; //包厢号 private String boxNum; public KTVConsumer(String name,String boxNum,long endTime){  this.name=name;  this.boxNum=boxNum;  this.endTime=endTime; } public String getName(){  return this.name; } public String getBoxNum(){  return this.boxNum; } /**  * 用来判断是否到了截止时间  */ @Override public long getDelay(TimeUnit unit) {  // TODO Auto-generated method stub  return unit.convert(endTime - System.currentTimeMillis(), TimeUnit.MILLISECONDS); } /**  * 相互比较排序用  */ @Override public int compareTo(Delayed o) {  // TODO Auto-generated method stub  if(o == null || ! (o instanceof KTVConsumer)) return 1;  if(o == this) return 0;  KTVConsumer s = (KTVConsumer)o;  return endTime - s.endTime > 0 ? 1 :(endTime - s.endTime == 0 ? 0 : -1); }}

运行的结果如下:

KTV正常营业================================张三 等人交了500元钱,进入111号包厢,开始K歌...李四 等人交了200元钱,进入666号包厢,开始K歌...王五 等人交了100元钱,进入888号包厢,开始K歌...================================李四 等人所在的666号包厢,时间到...王五 等人所在的888号包厢,时间到...张三 等人所在的111号包厢,时间到...

 

原标题:DelayQueue使用示例之KTV包厢记时

关键词:

*特别声明:以上内容来自于网络收集,著作权属原作者所有,如有侵权,请联系我们: admin#shaoqun.com (#换成@)。

外贸独立站建站(谷歌建站步骤) :https://www.goluckyvip.com/news/9356.html
TikTok Shop店铺差评率过高的主要原因 :https://www.goluckyvip.com/news/9357.html
外贸工厂转型TikTok,半年做到品牌榜第一:https://www.goluckyvip.com/news/9358.html
厦门首票跨境电商“1210”出口海外仓零售业务落地:https://www.goluckyvip.com/news/9359.html
虾皮Shopee运营规则频繁更新,不断提升平台体验感:https://www.goluckyvip.com/news/936.html
德国vat税造假可以吗-德国vat退税-德国vat税率:https://www.goluckyvip.com/news/9360.html
零售晚报:携程发布318成绩单 近800万商家GMV增长101% :https://www.kjdsnews.com/a/1836405.html
19点聊电商:百度云:大模型应用元年 企业如何先“卷”一步? :https://www.kjdsnews.com/a/1836406.html
相关文章
我的浏览记录
最新相关资讯
海外公司注册 | 跨境电商服务平台 | 深圳旅行社 | 东南亚物流