package com.example.test01.zhangch;

import java.util.Timer;
import java.util.TimerTask;

/**
 * @Author zhangch
 * @Description java 防抖
 * @Date 2022/8/4 18:18
 * @Version 1.0
 */
@SuppressWarnings("all")
public class DebounceTask {
    /**
     * 防抖實(shí)現(xiàn)關(guān)鍵類(lèi)
     */
    private Timer timer;
    /**
     * 防抖時(shí)間:根據(jù)業(yè)務(wù)評(píng)估
     */
    private Long delay;
    /**
     * 開(kāi)啟線程執(zhí)行任務(wù)
     */
    private Runnable runnable;

    public DebounceTask(Runnable runnable,  Long delay) {
        this.runnable = runnable;
        this.delay = delay;
    }

    /**
     *
     * @param runnable 要執(zhí)行的任務(wù)
     * @param delay 執(zhí)行時(shí)間
     * @return 初始化 DebounceTask 對(duì)象
     */
    public static DebounceTask build(Runnable runnable, Long delay){
        return new DebounceTask(runnable, delay);
    }

    //Timer類(lèi)執(zhí)行:cancel()-->取消操作；schedule()-->執(zhí)行操作
    public void timerRun(){
        //如果有任務(wù),則取消不執(zhí)行(防抖實(shí)現(xiàn)的關(guān)鍵)
        if(timer!=null){
            timer.cancel();
        }
        timer = new Timer();
        timer.schedule(new TimerTask() {
            @Override
            public void run() {
                //把 timer 設(shè)置為空,這樣下次判斷它就不會(huì)執(zhí)行了
                timer=null;
                //執(zhí)行 runnable 中的 run()方法
                runnable.run();
            }
        }, delay);
    }
}

public static void main(String[] args){
    //構(gòu)建對(duì)象，1000L: 1秒執(zhí)行-->1秒內(nèi)沒(méi)有請(qǐng)求，在執(zhí)行防抖操作
    DebounceTask task = DebounceTask.build(new Runnable() {
        @Override
        public void run() {
            System.out.println("防抖操作執(zhí)行了:do task: "+System.currentTimeMillis());
        }
    },1000L);
    long delay = 100;
    while (true){
        System.out.println("請(qǐng)求執(zhí)行:call task: "+System.currentTimeMillis());
        task.timerRun();
        try {
            //休眠1毫秒在請(qǐng)求
            Thread.sleep(delay);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

public static void main(String[] args){
    //構(gòu)建對(duì)象，1000L:1秒執(zhí)行
    DebounceTask task = DebounceTask.build(new Runnable() {
        @Override
        public void run() {
            System.out.println("防抖操作執(zhí)行了:do task: "+System.currentTimeMillis());
        }
    },1000L);
    long delay = 100;
    long douDelay = 0;
    while (true){
        System.out.println("請(qǐng)求執(zhí)行:call task: "+System.currentTimeMillis());
        task.timerRun();
        douDelay = douDelay+100;
        try {
            //如果請(qǐng)求執(zhí)行了兩秒,我們讓他先休息兩秒,在接著請(qǐng)求
            if (douDelay == 2000){
                Thread.sleep(douDelay);
            }
            Thread.sleep(delay);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

public static void main(String[] args){
    //要執(zhí)行的任務(wù),因?yàn)?Runnable 是接口,所以 new 對(duì)象的時(shí)候要實(shí)現(xiàn)它的 run方法
    Runnable runnable =  new Runnable() {
        @Override
        public void run() {
            //執(zhí)行打印,真實(shí)開(kāi)發(fā)中,是這些我們的業(yè)務(wù)代碼。
            System.out.println("防抖操作執(zhí)行了:do task: "+System.currentTimeMillis());
        }
    };

    //runnable:要執(zhí)行的任務(wù),通過(guò)參數(shù)傳遞進(jìn)去。1000L:1秒執(zhí)行內(nèi)沒(méi)有請(qǐng)求,就執(zhí)行一次防抖操作
    DebounceTask task = DebounceTask.build(runnable,1000L);
    //請(qǐng)求持續(xù)時(shí)間
    long delay = 100;
    //休眠時(shí)間,為了讓防抖任務(wù)執(zhí)行
    long douDelay = 0;

    //while 死循環(huán),請(qǐng)求一直執(zhí)行
    while (true){
        System.out.println("請(qǐng)求執(zhí)行:call task: "+System.currentTimeMillis());
        //調(diào)用 DebounceTask 防抖類(lèi)中的 timerRun() 方法, 執(zhí)行防抖任務(wù)
        task.timerRun();
        douDelay = douDelay+100;
        try {
            //如果請(qǐng)求執(zhí)行了兩秒,我們讓他先休息兩秒,在接著請(qǐng)求
            if (douDelay == 2000){
                Thread.sleep(douDelay);
            }
            Thread.sleep(delay);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

package com.example.test01.zhangch;

import java.util.Timer;
import java.util.TimerTask;

/**
 * @Author zhangch
 * @Description 節(jié)流
 * @Date 2022/8/6 15:41
 * @Version 1.0
 */
public class ThrottleTask {
    /**
     * 節(jié)流實(shí)現(xiàn)關(guān)鍵類(lèi)
     */
    private Timer timer;
    private Long delay;
    private Runnable runnable;
    private boolean needWait=false;

    /**
     * 有參構(gòu)造函數(shù)
     * @param runnable 要啟動(dòng)的定時(shí)任務(wù)
     * @param delay 延遲時(shí)間
     */
    public ThrottleTask(Runnable runnable,  Long delay) {
        this.runnable = runnable;
        this.delay = delay;
        this.timer = new Timer();
    }

    /**
     * build 創(chuàng)建對(duì)象，相當(dāng)于 ThrottleTask task = new ThrottleTask();
     * @param runnable 要執(zhí)行的節(jié)流任務(wù)
     * @param delay 延遲時(shí)間
     * @return ThrottleTask 對(duì)象
     */
    public static ThrottleTask build(Runnable runnable, Long delay){
        return new ThrottleTask(runnable, delay);
    }

    public void taskRun(){
        //如果 needWait 為 false,結(jié)果取反，表達(dá)式為 true。執(zhí)行 if 語(yǔ)句 
        if(!needWait){
            //設(shè)置為 true,這樣下次就不會(huì)再執(zhí)行
            needWait=true;
            //執(zhí)行節(jié)流方法
            timer.schedule(new TimerTask() {
                @Override
                public void run() {
                    //執(zhí)行完成,設(shè)置為 false,讓下次操作再進(jìn)入 if 語(yǔ)句中
                    needWait=false;
                    //開(kāi)啟多線程執(zhí)行 run() 方法
                    runnable.run();
                }
            }, delay);
        }
    }
}

public static void main(String[] args){
    //創(chuàng)建節(jié)流要執(zhí)行的對(duì)象,并把要執(zhí)行的任務(wù)傳入進(jìn)去
    ThrottleTask task = ThrottleTask.build(new Runnable() {
        @Override
        public void run() {
            System.out.println("節(jié)流任務(wù)執(zhí)行：do task: "+System.currentTimeMillis());
        }
    },1000L);
    //while一直執(zhí)行,模擬前端用戶一直請(qǐng)求后端
    while (true){
        System.out.println("前端請(qǐng)求后端：call task: "+System.currentTimeMillis());
        task.taskRun();
        try {
            Thread.sleep(200);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

public class ThrottleTask {
    /**
     * 節(jié)流實(shí)現(xiàn)關(guān)鍵類(lèi)：
     */
    private ScheduledExecutorService timer;
    private Long delay;
    private Runnable runnable;
    private boolean needWait=false;

    /**
     * 有參構(gòu)造函數(shù)
     * @param runnable 要啟動(dòng)的定時(shí)任務(wù)
     * @param delay 延遲時(shí)間
     */
    public ThrottleTask(Runnable runnable,  Long delay) {
        this.runnable = runnable;
        this.delay = delay;
        this.timer = Executors.newSingleThreadScheduledExecutor();
    }

    /**
     * build 創(chuàng)建對(duì)象，相當(dāng)于 ThrottleTask task = new ThrottleTask();
     * @param runnable 要執(zhí)行的節(jié)流任務(wù)
     * @param delay 延遲時(shí)間
     * @return ThrottleTask 對(duì)象
     */
    public static ThrottleTask build(Runnable runnable, Long delay){
        return new ThrottleTask(runnable, delay);
    }

    public void taskRun(){
        //如果 needWait 為 false,結(jié)果取反，表達(dá)式為 true。執(zhí)行 if 語(yǔ)句
        if(!needWait){
            //設(shè)置為 true,這樣下次就不會(huì)再執(zhí)行
            needWait=true;
            //執(zhí)行節(jié)流方法
            timer.schedule(new TimerTask() {
                @Override
                public void run() {
                    //執(zhí)行完成,設(shè)置為 false,讓下次操作再進(jìn)入 if 語(yǔ)句中
                    needWait=false;
                    //開(kāi)啟多線程執(zhí)行 run() 方法
                    runnable.run();
                }
            }, delay,TimeUnit.MILLISECONDS);
        }
    }
}