import java.util.Timer;
import java.util.TimerTask;
import java.util.concurrent.PriorityBlockingQueue;

public class TimeProgram {
    public static void main(String[] args) throws InterruptedException {
        Timer timer = new Timer();
        timer.schedule(new TimerTask() {
            @Override
            public void run() {
                System.out.println("執(zhí)行延后2s執(zhí)行的任務(wù)！");
            }
        }, 2000);
        timer.schedule(new TimerTask() {
            @Override
            public void run() {
                System.out.println("執(zhí)行延后5s執(zhí)行的任務(wù)！");
            }
        }, 5000);

        //每秒輸出一個(gè)mian
        for (int i = 0; i < 5; i++) {
            System.out.println("main");
            Thread.sleep(1000);
        }
    }
}

public abstract class TimerTask implements Runnable    //jdk源碼

//我的任務(wù)
class MyTask implements Comparable<MyTask> {
    //接收具體任務(wù)
    private Runnable runnable;
    //執(zhí)行時(shí)的時(shí)間戳
    private long time;

    //構(gòu)造方法
    public MyTask(Runnable runnable, int delay) {
        this.runnable = runnable;
        this.time = System.currentTimeMillis() + delay;
    }

    //執(zhí)行任務(wù)
    public void run() {
        this.runnable.run();
    }
    //獲取執(zhí)行時(shí)間
    public long getTime() {
        return this.time;
    }

    //實(shí)現(xiàn)comparable接口,方便創(chuàng)建優(yōu)先級(jí)阻塞隊(duì)列
    @Override
    public int compareTo(MyTask o) {
        return (int) (this.time - o.time);
    }
}

    //每次執(zhí)行任務(wù)時(shí)，需要優(yōu)先執(zhí)行時(shí)間在前的任務(wù)，即每次執(zhí)行任務(wù)要選擇時(shí)間戳最小的任務(wù)，在多線程情況中優(yōu)先級(jí)阻塞隊(duì)列是最佳選擇
    private static final PriorityBlockingQueue<MyTask> priorityBlockingQueue = new PriorityBlockingQueue<>();

//我的定時(shí)類 用來管理任務(wù)
class MyTimer {
    //專門對(duì)鎖對(duì)象
    private final Object locker = new Object();
    //每次執(zhí)行任務(wù)時(shí)，需要優(yōu)先執(zhí)行時(shí)間在前的任務(wù)，即每次執(zhí)行任務(wù)要選擇時(shí)間戳最小的任務(wù)，在多線程情況中優(yōu)先級(jí)阻塞隊(duì)列是最佳選擇
    private static final PriorityBlockingQueue<MyTask> priorityBlockingQueue = new PriorityBlockingQueue<>();

    //安排任務(wù)
    public void schedule(Runnable runnable, int delay) {
        //將任務(wù)放入小根堆中
        MyTask task = new MyTask(runnable, delay);
        priorityBlockingQueue.put(task);
        //每次當(dāng)新任務(wù)加載到阻塞隊(duì)列時(shí)，需要中途喚醒線程，因?yàn)樾逻M(jìn)來的任務(wù)可能是最早需要執(zhí)行的
        synchronized (locker) {
            locker.notify();
        }
    }
    public MyTimer() {
        Thread thread = new Thread(() -> {
            while (true) {
                try {
                    //加載任務(wù)，確定執(zhí)行時(shí)機(jī)
                    MyTask myTask = priorityBlockingQueue.take();
                    long curTime = System.currentTimeMillis();
                    //時(shí)間未到，將任務(wù)放回
                    if (curTime < myTask.getTime()) {
                        synchronized (locker) {
                            priorityBlockingQueue.put(myTask);
                            //放回任務(wù)后，不能立即就再次取該任務(wù)加載，需要設(shè)置一個(gè)再次加載的等待時(shí)間,建議使用wait帶參數(shù)的方法
                            //因?yàn)閣ait方法可以使用notify進(jìn)行中途喚醒，而sleep不能中途喚醒
                            int delay = (int)(myTask.getTime() - curTime);
                            locker.wait(delay);
                        }
                    } else {
                        System.out.println(Thread.currentThread().getName() + "線程收到任務(wù)，正在執(zhí)行中！");
                        myTask.run();
                        System.out.println(Thread.currentThread().getName() + "線程執(zhí)行任務(wù)完畢，正在等待新任務(wù)！");
                    }
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        });
        //不要忘了啟動(dòng)線程
        thread.start();
    }
}

import java.util.TimerTask;
import java.util.concurrent.PriorityBlockingQueue;

public class TimeProgram {
    public static void main(String[] args) throws InterruptedException {
        MyTimer timer = new MyTimer();
        timer.schedule(new TimerTask() {
            @Override
            public void run() {
                System.out.println("執(zhí)行延后2s執(zhí)行的任務(wù)！");
            }
        }, 2000);
        timer.schedule(new TimerTask() {
            @Override
            public void run() {
                System.out.println("執(zhí)行延后5s執(zhí)行的任務(wù)！");
            }
        }, 5000);

        //每秒輸出一個(gè)mian
        for (int i = 0; i < 5; i++) {
            System.out.println("main");
            Thread.sleep(1000);
        }
    }
}