Java多线程并发开发之DelayQueue使用示例

在学习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号包厢,时间到...

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。