| New file | 
 |  |  | 
 |  |  | package com.dy.common.util; | 
 |  |  |  | 
 |  |  | import org.apache.logging.log4j.LogManager; | 
 |  |  | import org.apache.logging.log4j.Logger; | 
 |  |  |  | 
 |  |  | /** | 
 |  |  |  * @Author: liurunyu | 
 |  |  |  * @Date: 2024/11/20 18:29 | 
 |  |  |  * @Description | 
 |  |  |  */ | 
 |  |  | public class TimerTaskJobTest extends TimerTaskJob implements Callback { | 
 |  |  |  | 
 |  |  |     private static int count = 0 ; | 
 |  |  |  | 
 |  |  |     public static void main(String[] args) throws Exception { | 
 |  |  |         TimerTaskJobTest obj = new TimerTaskJobTest() ; | 
 |  |  |         obj.start(1000L,  1000L, obj); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     public Object execute() { | 
 |  |  |         count++ ; | 
 |  |  |         System.out.println("执行伺服线程" + count + "次"); | 
 |  |  |         if(count == 10) { | 
 |  |  |             stop() ; | 
 |  |  |         } | 
 |  |  |         return true ; | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     //////////////////////////////////////////////////// | 
 |  |  |     // | 
 |  |  |     // 升级状态通知工作线程执行完成后回调的方法, | 
 |  |  |     // 也就是上面execute方法执行完成返回或抛出异常后,执行下面三个方法 | 
 |  |  |     // | 
 |  |  |     //////////////////////////////////////////////////// | 
 |  |  |     @Override | 
 |  |  |     public void call(Object obj) { | 
 |  |  |         //线程工作执行一次,obj = Boolean(true) | 
 |  |  |         System.out.println("伺服线程执行一次回调"); | 
 |  |  |     } | 
 |  |  |     @Override | 
 |  |  |     public void call(Object... objs) { | 
 |  |  |     } | 
 |  |  |     @Override | 
 |  |  |     public void exception(Exception e) { | 
 |  |  |         e.printStackTrace(); | 
 |  |  |         System.out.println("伺服线程发生异常" + e.getMessage()); | 
 |  |  |     } | 
 |  |  | } |