package com.changhong.epc.parsing.service.loop.tools.thread;
|
|
import com.changhong.epc.parsing.service.loop.tools.Perform;
|
import lombok.extern.slf4j.Slf4j;
|
|
/**
|
* 增强 Thread 线程
|
* @author wzx
|
*
|
*/
|
@Slf4j
|
public class MyThread extends Thread{
|
|
|
private boolean isRun = true;
|
|
private Perform perform;
|
private String threadName;
|
|
// 睡眠时间
|
private long sleepTime;
|
|
// 线程创建的时间
|
private long startTime ;
|
|
// 执行一次业务所用的时间
|
private long onceServiceRunTime;
|
|
public MyThread(Perform perform, String threadName, long sleepTime) {
|
this.perform = perform;
|
this.threadName = threadName;
|
this.sleepTime = sleepTime;
|
super.setName(this.threadName);
|
}
|
|
@Override
|
public void run() {
|
startTime = System.currentTimeMillis();
|
while(isRun){
|
try {
|
long st = System.currentTimeMillis();
|
perform.execute();
|
long et = System.currentTimeMillis();
|
onceServiceRunTime = et -st;
|
Thread.sleep(sleepTime);
|
} catch (Exception e) {
|
log.error(e.getMessage(), e);
|
try {
|
Thread.sleep(sleepTime);
|
} catch (InterruptedException e1) {
|
log.error(e1.getMessage(), e1);
|
Thread.currentThread().interrupt();
|
}
|
}
|
}
|
|
}
|
|
|
|
public boolean isRun() {
|
return isRun;
|
}
|
|
public void setRun(boolean isRun) {
|
this.isRun = isRun;
|
}
|
/**
|
* 当前线程运行的时间
|
* @return 毫秒数
|
*/
|
public long getCurrThreadRunTime() {
|
return System.currentTimeMillis() - startTime;
|
}
|
|
|
/**
|
* 获取执行间隔时间 毫秒数
|
* @return
|
*/
|
public long getSleepTime() {
|
return sleepTime;
|
}
|
|
/**
|
* 设置执行间隔时间 毫秒数
|
* @param sleepTime
|
*/
|
public void setSleepTime(long sleepTime) {
|
this.sleepTime = sleepTime;
|
}
|
|
/**
|
* 获得当前线程名称
|
* @return
|
*/
|
public String getThreadName() {
|
return threadName;
|
}
|
|
/**
|
* 获得当前线程启动的时间
|
* @return
|
*/
|
public long getStartTime() {
|
return startTime;
|
}
|
|
public void setPerform(Perform perform) {
|
this.perform = perform;
|
}
|
|
|
/**
|
* 执行本次业务所用的时间
|
* @return
|
*/
|
public long getOnceServiceRunTime() {
|
return onceServiceRunTime;
|
}
|
|
|
|
|
|
}
|
