整理版本

zhubaomin

2025-04-07 1a2b07f01ba4616fd9e894dddf474b56d020158c

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/util/TimerTaskJob.java

New file
@@ -0,0 +1,63 @@
package com.dy.common.util;

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

/**
 * @Author: liurunyu
 * @Date: 2024/11/20 17:49
 * @Description :
 * 2024-11-20：
 * 此抽象类代替ThreadJob，原因：
 * 在while(true){}中使用Thread.sleep()，可能导致的严重性能问题，不推荐在循环中使用线程休眠。
 * Java线程实现采用内核线程实现，线程的休眠及唤醒（状态切换）需借助操作系统进行，这是一个极其耗时耗力的操作。
 * 在线程休眠或运行时间较长的情景下，其对性能的影响还不算明显，因为对线程状态的切换并不频繁。
 * 但若线程休眠及运行的时间都很短（例如毫秒/秒），
 * 系统将频繁的对线程状态进行切换，导致严重的性能损耗，并对着循环次数的递增而放大。
 */
public abstract class TimerTaskJob {
    protected Timer timer;

    protected boolean stop = false ;
    public void stop(){
        this.stop = true ;
        if(this.timer != null){
            this.timer.cancel();
        }
    }
    public boolean isStop(){
        return this.stop ;
    }

    /**
     *
     * @param delay
     * @param interval
     * @param callback
     * @throws Exception
     */
    public void start(Long delay, Long interval, Callback callback) throws Exception {
        this.timer = new Timer();
        this.timer.schedule(new TimerTask() {
            public void run() {
                Exception exe = null ;
                Object obj = null ;
                try {
                    obj = execute() ;
                }catch(Exception e){
                    e.printStackTrace();
                    exe = e ;
                }finally {
                    if(callback != null){
                        if(exe != null){
                            callback.exception(exe);
                        }else{
                            callback.call(obj);
                        }
                    }
                }
            }
        }, delay , interval);
    }
    public abstract Object execute() throws Exception ;
}