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());
|
}
|
}
|
