package com.walker.scheduler.impl;
|
|
import com.walker.scheduler.util.OptionUtils;
|
|
/**
|
* 平台实现的“采集类型”调度器，特点是：无限循环，持续执行，无需设置周期。
|
* @author 时克英
|
* @date 2018-12-28
|
*
|
*/
|
public abstract class ForeverScheduler extends TimedScheduler {
|
|
// 如果执行调用后，未返回结果数据，就进入休眠（有休眠时间设置）
|
private boolean sleepForNotFoundData = true;
|
|
/**
|
* 设置参数：如果执行调用后，未返回结果数据，就进入休眠（有休眠时间设置）
|
* @param sleepForNotFoundData
|
*/
|
public void setSleepForNotFoundData(boolean sleepForNotFoundData) {
|
this.sleepForNotFoundData = sleepForNotFoundData;
|
}
|
|
public ForeverScheduler(int id, String name){
|
super(id, name);
|
this.setOption(OptionUtils.combineEveryDay24HourOption());
|
}
|
|
@Override
|
protected Object doRunOnce(Object[] inputParams) throws Exception {
|
this.firstRunForLazy();
|
Object result = this.onProcess(inputParams);
|
if(result == null && this.sleepForNotFoundData){
|
this.doChangeIntervalTime();
|
logger.debug("~~~~~~~~~~~~~~~~~~~~ 没有数据采集，线程休眠一次：" + this.getTimeInterval());
|
} else {
|
this.doResetIntervalTime();
|
}
|
|
return result;
|
}
|
|
@Override
|
protected Object[] getRunParameters(Object previousInvokeResult) {
|
return null;
|
}
|
|
}
|
