Java定時(shí)器實(shí)現(xiàn)的完整過(guò)程 附詳細(xì)實(shí)例代碼

static class Task implements Comparable<Task>{
        //Runnable類中有一個(gè)run方法， 通過(guò)這個(gè)方法實(shí)現(xiàn)任務(wù)的執(zhí)行
        private Runnable command;
        //time表示執(zhí)行的時(shí)間
        private long time;

        //構(gòu)造方法
        public Task(Runnable command, long time) {
            this.command = command;
            this.time = System.currentTimeMillis() + time;  //將時(shí)間轉(zhuǎn)化為絕對(duì)時(shí)間
        }

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

        //定義比較方法 - 方便后續(xù)的優(yōu)先級(jí)隊(duì)列構(gòu)建

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

//檢測(cè)線程， 繼承Thread類，重寫內(nèi)部run方法，屬于線程的創(chuàng)建方法之一。
    static class Worker extends Thread {
     //優(yōu)先級(jí)隊(duì)列 - JUC包里面
        private PriorityBlockingQueue<Task> queue = null;
        //為了對(duì)監(jiān)管線程進(jìn)行阻塞和喚醒，采用同一對(duì)象
        private Object mailBox = null;
  
  //構(gòu)造函數(shù)
        public Worker(PriorityBlockingQueue<Task> queue, Object mailBox) {
            this.queue = queue;
            this.mailBox = mailBox;
        }

        @Override
        public void run() {
            //實(shí)現(xiàn)具體的執(zhí)行邏輯
            while(true) {
                try {
                    //1、取優(yōu)先級(jí)隊(duì)列的隊(duì)首元素
                    Task task = queue.peek();
                    //2、比較隊(duì)首的元素的時(shí)間是否大于當(dāng)前時(shí)間
                    if(task == null) {
                        continue;
                    }
                    long curTime = System.currentTimeMillis();
                    if(task.time > curTime) {
                        //時(shí)間還沒(méi)有到， 由于取出了任務(wù)， 需要重新放置回去
                        //優(yōu)化1： 空循環(huán)等待 - wait(time) 讓線程休眠time時(shí)間，然后在執(zhí)行
                        //       如果在等待期間有新的任務(wù)添加， 這個(gè)時(shí)候我們喚醒線程， 繼續(xù)判斷（因?yàn)榇嬖谛碌臅r(shí)間過(guò)短需要立即執(zhí)行）
                        //       這個(gè)只需要添加一個(gè)新任務(wù)時(shí)， 喚醒即可
                        //優(yōu)化2： 訪問(wèn)隊(duì)首元素而不是取出， 防止無(wú)所謂的刪除、插入。（維護(hù)優(yōu)先級(jí)隊(duì)列是有消耗的）
                        long gapTime = task.time - curTime;
                        synchronized (mailBox) {
                            mailBox.wait(gapTime);
                        }
                    }
                    else {
                        //直接執(zhí)行
                        //如果執(zhí)行到了， 則會(huì)刪除頭部元素， 調(diào)用任務(wù)的執(zhí)行過(guò)程。
                        task = queue.take();
                        task.run();
                    }
                }
                catch(InterruptedException e) {
                    e.printStackTrace();
                    break;
                }
            }
        }
    }

    //定時(shí)器簡(jiǎn)單實(shí)現(xiàn)
    static class Timer {
        //定時(shí)器的實(shí)現(xiàn)步驟
        //1、用一個(gè)類描述任務(wù)
        //2、用優(yōu)先級(jí)隊(duì)列管理這些任務(wù)， 比較方法通過(guò)任務(wù)的制定時(shí)間，每次取隊(duì)首元素
        //   隊(duì)首元素是執(zhí)行時(shí)間最近的
        private PriorityBlockingQueue<Task> queue = new PriorityBlockingQueue<>();
        //3、用一個(gè)線程來(lái)循環(huán)掃描當(dāng)前的阻塞隊(duì)列，判斷隊(duì)首的執(zhí)行時(shí)間， 如果執(zhí)行時(shí)間到了，那就執(zhí)行。

        //4、創(chuàng)建一個(gè)Object對(duì)象，用于設(shè)置線程阻塞使用的， 存在線程阻塞， 添加任務(wù)時(shí)喚醒的操作
        private Object mailBox = new Object();

        //構(gòu)造函數(shù)
        public Timer() {
            //創(chuàng)建線程
            Worker worker = new Worker(queue, mailBox);
            worker.start();
        }


        //4、提供一個(gè)方法， 讓調(diào)用者能夠把任務(wù)安排起來(lái)
        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("郝夢(mèng)武一號(hào)任務(wù)執(zhí)行， 執(zhí)行代號(hào):閃電；  定時(shí)時(shí)間:2s");
            }
        }, 2000);

        timer.schedule(new Runnable() {
            @Override
            public void run() {
                System.out.println("郝夢(mèng)武二號(hào)任務(wù)執(zhí)行， 執(zhí)行代號(hào):暴風(fēng)；  定時(shí)時(shí)間:5s");
            }
        }, 5000);

        timer.schedule(new Runnable() {
            @Override
            public void run() {
                System.out.println("郝夢(mèng)武三號(hào)任務(wù)執(zhí)行， 執(zhí)行代號(hào):狂風(fēng)；  定時(shí)時(shí)間:7s");
            }
        }, 7000);

        timer.schedule(new Runnable() {
            @Override
            public void run() {
                System.out.println("郝夢(mèng)武三號(hào)任務(wù)執(zhí)行， 執(zhí)行代號(hào):地震；  定時(shí)時(shí)間:10s");
            }
        }, 10000);
    }