pipIrr-SV.git - Gitblit

New file
			@@ -0,0 +1,48 @@
			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());
			}
			}