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 {
    /**
     * 防抖實現(xiàn)關鍵類
     */
    private Timer timer;
    /**
     * 防抖時間:根據(jù)業(yè)務評估
     */
    private Long delay;
    /**
     * 開啟線程執(zhí)行任務
     */
    private Runnable runnable;

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

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

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

public static void main(String[] args){
    //構建對象，1000L: 1秒執(zhí)行-->1秒內(nèi)沒有請求，在執(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("請求執(zhí)行:call task: "+System.currentTimeMillis());
        task.timerRun();
        try {
            //休眠1毫秒在請求
            Thread.sleep(delay);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

public static void main(String[] args){
    //構建對象，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("請求執(zhí)行:call task: "+System.currentTimeMillis());
        task.timerRun();
        douDelay = douDelay+100;
        try {
            //如果請求執(zhí)行了兩秒,我們讓他先休息兩秒,在接著請求
            if (douDelay == 2000){
                Thread.sleep(douDelay);
            }
            Thread.sleep(delay);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

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

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

    //while 死循環(huán),請求一直執(zhí)行
    while (true){
        System.out.println("請求執(zhí)行:call task: "+System.currentTimeMillis());
        //調(diào)用 DebounceTask 防抖類中的 timerRun() 方法, 執(zhí)行防抖任務
        task.timerRun();
        douDelay = douDelay+100;
        try {
            //如果請求執(zhí)行了兩秒,我們讓他先休息兩秒,在接著請求
            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é)流實現(xiàn)關鍵類
     */
    private Timer timer;
    private Long delay;
    private Runnable runnable;
    private boolean needWait=false;

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

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

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

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

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

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

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

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