Java簡單實現定時器

static class Task implements Comparable<Task>{
        //Runnable類中有一個run方法， 通過這個方法實現任務的執行
        private Runnable command;
        //time表示執行的時間
        private long time;

        //構造方法
        public Task(Runnable command, long time) {
            this.command = command;
            this.time = System.currentTimeMillis() + time;  //將時間轉化為絕對時間
        }

        //執行任務的邏輯
        public void run() {
            command.run();
        }

        //定義比較方法 - 方便後續的優先級隊列構建

        @Override
        public int compareTo(Task o) {
            return (int)(this.time - o.time);
        }
    }

//檢測線程， 繼承Thread類，重寫內部run方法，屬於線程的創建方法之一。
    static class Worker extends Thread {
     //優先級隊列 - JUC包裡面
        private PriorityBlockingQueue<Task> queue = null;
        //為瞭對監管線程進行阻塞和喚醒，采用同一對象
        private Object mailBox = null;
  
  //構造函數
        public Worker(PriorityBlockingQueue<Task> queue, Object mailBox) {
            this.queue = queue;
            this.mailBox = mailBox;
        }

        @Override
        public void run() {
            //實現具體的執行邏輯
            while(true) {
                try {
                    //1、取優先級隊列的隊首元素
                    Task task = queue.peek();
                    //2、比較隊首的元素的時間是否大於當前時間
                    if(task == null) {
                        continue;
                    }
                    long curTime = System.currentTimeMillis();
                    if(task.time > curTime) {
                        //時間還沒有到， 由於取出瞭任務， 需要重新放置回去
                        //優化1： 空循環等待 - wait(time) 讓線程休眠time時間，然後在執行
                        //       如果在等待期間有新的任務添加， 這個時候我們喚醒線程， 繼續判斷（因為存在新的時間過短需要立即執行）
                        //       這個隻需要添加一個新任務時， 喚醒即可
                        //優化2： 訪問隊首元素而不是取出， 防止無所謂的刪除、插入。（維護優先級隊列是有消耗的）
                        long gapTime = task.time - curTime;
                        synchronized (mailBox) {
                            mailBox.wait(gapTime);
                        }
                    }
                    else {
                        //直接執行
                        //如果執行到瞭， 則會刪除頭部元素， 調用任務的執行過程。
                        task = queue.take();
                        task.run();
                    }
                }
                catch(InterruptedException e) {
                    e.printStackTrace();
                    break;
                }
            }
        }
    }

    //定時器簡單實現
    static class Timer {
        //定時器的實現步驟
        //1、用一個類描述任務
        //2、用優先級隊列管理這些任務， 比較方法通過任務的制定時間，每次取隊首元素
        //   隊首元素是執行時間最近的
        private PriorityBlockingQueue<Task> queue = new PriorityBlockingQueue<>();
        //3、用一個線程來循環掃描當前的阻塞隊列，判斷隊首的執行時間， 如果執行時間到瞭，那就執行。

        //4、創建一個Object對象，用於設置線程阻塞使用的， 存在線程阻塞， 添加任務時喚醒的操作
        private Object mailBox = new Object();

        //構造函數
        public Timer() {
            //創建線程
            Worker worker = new Worker(queue, mailBox);
            worker.start();
        }


        //4、提供一個方法， 讓調用者能夠把任務安排起來
        public void schedule(Runnable command, long time) {
            Task task = new Task(command, time);
            queue.put(task);
            synchronized (mailBox) {
                mailBox.notify();
            }
        }
    }

public static void main(String[] args) {
        Timer timer = new Timer();
        timer.schedule(new Runnable() {
            @Override
            public void run() {
                System.out.println("郝夢武一號任務執行， 執行代號:閃電；  定時時間:2s");
            }
        }, 2000);

        timer.schedule(new Runnable() {
            @Override
            public void run() {
                System.out.println("郝夢武二號任務執行， 執行代號:暴風；  定時時間:5s");
            }
        }, 5000);

        timer.schedule(new Runnable() {
            @Override
            public void run() {
                System.out.println("郝夢武三號任務執行， 執行代號:狂風；  定時時間:7s");
            }
        }, 7000);

        timer.schedule(new Runnable() {
            @Override
            public void run() {
                System.out.println("郝夢武三號任務執行， 執行代號:地震；  定時時間:10s");
            }
        }, 10000);
    }