package com.dy.common.mw.core;
|
|
import org.apache.logging.log4j.LogManager;
|
import org.apache.logging.log4j.Logger;
|
|
/**
|
* @Author liurunyu
|
* @Date 2023/12/19 16:41
|
* @LastEditTime 2023/12/19 16:41
|
* @Description
|
*/
|
/**
|
* 2024-11-21 该类已经弃用，改由CoreConstantTimer实现。
|
* 当采用Thread实现时，在while(true){}中使用Thread.sleep()，可能导致的严重性能问题，不推荐在循环中使用线程休眠。
|
* Java线程实现采用内核线程实现，线程的休眠及唤醒（状态切换）需借助操作系统进行，这是一个极其耗时耗力的操作。
|
* 在线程休眠或运行时间较长的情景下，其对性能的影响还不算明显，因为对线程状态的切换并不频繁。
|
* 但若线程休眠及运行的时间都很短（例如毫秒/秒），
|
* 系统将频繁的对线程状态进行切换，导致严重的性能损耗，并对着循环次数的递增而放大。
|
*/
|
@Deprecated
|
public class CoreConstantThread extends Thread {
|
|
private final static Logger log = LogManager.getLogger(CoreConstantThread.class.getName()) ;
|
|
private long sleepBigBusy ;
|
private long sleepSmallBusy ;
|
private CoreTask task ;
|
|
public CoreConstantThread(long sleepBigBusy, long sleepSmallBusy, CoreTask task){
|
this.sleepBigBusy = sleepBigBusy ;
|
this.sleepSmallBusy = sleepSmallBusy ;
|
this.task = task ;
|
}
|
|
@Override
|
public void run() {
|
if(task != null){
|
int count ;
|
while (true) {
|
try {
|
count = task.execute();
|
if (count == 0) {
|
//小暂停一下
|
Thread.sleep(sleepBigBusy);
|
}else{
|
Thread.sleep(sleepSmallBusy);
|
}
|
} catch (Exception e) {
|
log.error("恒久任务" + task.getClass().getName() + "执行时发生异常" + (e.getMessage() == null ? "" : (":" + e.getMessage())), e);
|
}
|
}
|
}
|
}
|
}
|
