| New file | 
|  |  |  | 
|---|
|  |  |  | 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 ; | 
|---|
|  |  |  | } | 
|---|