package com.walker.scheduler.impl;

import com.walker.scheduler.AbstractKernelScheduler;

import java.util.concurrent.TimeUnit;

/**
 * 平台定时调度器实现，该对象必须设置定时时间，支持：</p>
 * <pre>
 * 1、只执行一次（具体时间）
 * 2、周期执行（时间循环或时间范围内）
 * </pre>
 * @author 时克英
 * @date 2018-12-28
 *
 */
public abstract class TimedScheduler extends AbstractKernelScheduler {

	// 初始化状态，防止刚启动就执行，带了问题
	private boolean firstLazy = false;

	public TimedScheduler(int id, String name){
		super(id, name);
	}

	@Override
	protected Object doRunOnce(Object[] inputParams) throws Exception {
		this.firstRunForLazy();
		return this.onProcess(inputParams);
	}

	@Override
	protected Object[] getRunParameters(Object previousInvokeResult) {
		return null;
	}

	/**
	 * 业务调用实现，实际执行一次计算调用
	 * @param inputParams 每次getRunParameters()方法返回的参数
	 * @return 返回本次调用处理的结果数据，如果没有为空。可作为下次是否执行的凭证
	 */
	protected abstract Object onProcess(Object[] inputParams) throws Exception;
	
	protected void firstRunForLazy(){
		if(!firstLazy){
			try {
				// 让启动线程等待一会，防止系统还没启动完，就开始加载对象
				TimeUnit.SECONDS.sleep(10);
			} catch (InterruptedException e) {
				e.printStackTrace();
			} finally {
				firstLazy = true;
			}
		}
	}
}