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号包廂,時間到...