延時阻塞佇列DelayQueue是一種特殊的優先順序佇列，它也是無界的，它要求每個元素都實現Delayed介面，該介面的宣告為：

public interface Delayed extends Comparable<Delayed> {
    long getDelay(TimeUnit unit);
}

Delayed擴充套件了Comparable介面，也就是說，DelayQueue的每個元素都是可比較的，它有一個額外方法getDelay返回一個給定時間單位unit的整數，表示再延遲多長時間，如果小於等於0，表示不再延遲。

DelayQueue也是優先順序佇列，它按元素的延時時間出隊，它的特殊之處在於，只有當元素的延時過期之後才能被從佇列中拿走，也就是說，take方法總是返回第一個過期的元素，如果沒有，則阻塞等待。

DelayQueue可以用於實現定時任務，我們看段簡單的示例程式碼：

public class DelayedQueueDemo {
    private static final AtomicLong taskSequencer = new AtomicLong(0);

    static class DelayedTask implements Delayed {
        private long runTime;
        private long sequence;
        private Runnable task;

        public DelayedTask(int delayedSeconds, Runnable task) {
            this.runTime = System.currentTimeMillis() + delayedSeconds * 1000;
            this.sequence = taskSequencer.getAndIncrement();
            this.task = task;
        }

        @Override
        public int compareTo(Delayed o) {
            if (o == this) {
                return 0;
            }
            if (o instanceof DelayedTask) {
                DelayedTask other = (DelayedTask) o;
                if (runTime < other.runTime) {
                    return -1;
                } else if (runTime > other.runTime) {
                    return 1;
                } else if (sequence < other.sequence) {
                    return -1;
                } else {
                    return 1;
                }
            }
            throw new IllegalArgumentException();
        }

        @Override
        public long getDelay(TimeUnit unit) {
            return unit.convert(runTime - System.currentTimeMillis(),
                    TimeUnit.MICROSECONDS);
        }

        public Runnable getTask() {
            return task;
        }
    }

    public static void main(String[] args) throws InterruptedException {
        DelayQueue<DelayedTask> tasks = new DelayQueue<>();
        tasks.put(new DelayedTask(2, new Runnable() {
            @Override
            public void run() {
                System.out.println("execute delayed task");
            }
        }));

        DelayedTask task = tasks.take();
        task.getTask().run();
    }
}

DelayedTask表示延時任務，只有延時過期後任務才會執行，任務按延時時間排序，延時一樣的按照入隊順序排序。

內部，DelayQueue是基於PriorityQueue實現的，它使用一個鎖ReentrantLock保護所有訪問，使用一個條件available表示頭部是否有元素，當頭部元素的延時未到時，take操作會根據延時計算需睡眠的時間，然後睡眠，如果在此過程中有新的元素入隊，且成為頭部元素，則阻塞睡眠的執行緒會被提前喚醒然後重新檢查。以上是基本思路，DelayQueue的實現有一些優化，以減少不必要的喚醒，具體我們就不探討了。

模擬一個考試的日子，考試時間為120分鐘，30分鐘後才可交卷，當時間到了，或學生都交完捲了考試結束。

這個場景中幾個點需要注意：

1. 考試時間為120分鐘，30分鐘後才可交卷，初始化考生完成試卷時間最小應為30分鐘
2. 對於能夠在120分鐘內交卷的考生，如何實現這些考生交卷
3. 對於120分鐘內沒有完成考試的考生，在120分鐘考試時間到後需要讓他們強制交卷
4. 在所有的考生都交完卷後，需要將控制執行緒關閉

抽象出兩個類，學生類和老師類，用DelayQueue儲存考生（Student類）。每一個考生都有自己的名字和完成試卷的時間

Teacher執行緒對DelayQueue進行監控，收取完成試卷小於120分鐘的學生的試卷。當考試時間120分鐘到時，teacher執行緒宣佈考試結束，強制DelayQueue中還存在的考生交卷。