com.fr.schedule.feature.job

类 AbstractScheduleJob

java.lang.Object

com.fr.scheduler.job.FineScheduleJob

com.fr.schedule.feature.job.AbstractScheduleJob

所有已实现的接口:

com.fr.third.v2.org.quartz.Job

直接已知子类:

AbstractExecuteJob, BaseCalculationJob, ExecuteResultJob

public abstract class AbstractScheduleJob
extends FineScheduleJob

Created by Zed on 2017/11/16. 在这里实现集群环境下的定时任务执行逻辑

字段概要

字段

限定符和类型	字段和说明
static FineLoggerProvider	log

构造器概要

构造器

构造器和说明
AbstractScheduleJob()

方法概要

方法

限定符和类型	方法和说明
void	dealWithException(ScheduleTask scheduleTask, java.lang.Class<? extends com.fr.third.v2.org.quartz.Job> jobClass, boolean skip) 处理异常情况（重启）
abstract void	doJob(com.fr.third.v2.org.quartz.JobExecutionContext jobExecutionContext)
java.lang.String	getTaskLockName(com.fr.third.v2.org.quartz.JobExecutionContext context)
void	recordError(ScheduleTask scheduleTask, java.lang.Exception exception, java.lang.Class<? extends com.fr.third.v2.org.quartz.Job> jobClass, boolean isSkip, java.lang.String currentUserName, RunType runType) 记录错误信息
void	recordSuccess(ScheduleTask scheduleTask, java.lang.String currentUserName, RunType runType) 记录成功执行信息
void	recordThreadError(java.lang.Exception exc) 记录线程超时退出
void	restartJob(ScheduleTask scheduleTask, java.lang.Class<? extends com.fr.third.v2.org.quartz.Job> jobClass) 重启定时任务
void	run(com.fr.third.v2.org.quartz.JobExecutionContext context, ClusterNode node)

从类继承的方法 com.fr.scheduler.job.FineScheduleJob

execute

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

log

public static FineLoggerProvider log

构造器详细资料

AbstractScheduleJob

public AbstractScheduleJob()

方法详细资料

run

public void run(com.fr.third.v2.org.quartz.JobExecutionContext context,
       ClusterNode node)

指定者:

run 在类中 FineScheduleJob

getTaskLockName

public java.lang.String getTaskLockName(com.fr.third.v2.org.quartz.JobExecutionContext context)

覆盖:

getTaskLockName 在类中 FineScheduleJob

doJob

public abstract void doJob(com.fr.third.v2.org.quartz.JobExecutionContext jobExecutionContext)

recordError

public void recordError(ScheduleTask scheduleTask,
               java.lang.Exception exception,
               java.lang.Class<? extends com.fr.third.v2.org.quartz.Job> jobClass,
               boolean isSkip,
               java.lang.String currentUserName,
               RunType runType)

记录错误信息

参数:

scheduleTask - 任务

exception - 异常

jobClass - job类

isSkip - 是否为跳过

currentUserName - 当前用户名

runType - 日志运行类型

recordSuccess

public void recordSuccess(ScheduleTask scheduleTask,
                 java.lang.String currentUserName,
                 RunType runType)

记录成功执行信息

参数:

scheduleTask - 任务

currentUserName - 当前用户名称

runType - 日志运行类型

recordThreadError

public void recordThreadError(java.lang.Exception exc)

记录线程超时退出

参数:

exc - 异常

dealWithException

public void dealWithException(ScheduleTask scheduleTask,
                     java.lang.Class<? extends com.fr.third.v2.org.quartz.Job> jobClass,
                     boolean skip)

处理异常情况（重启）

参数:

scheduleTask - 任务对象

jobClass - job class

skip - 是否跳过

restartJob

public void restartJob(ScheduleTask scheduleTask,
              java.lang.Class<? extends com.fr.third.v2.org.quartz.Job> jobClass)

重启定时任务

参数:

scheduleTask - 任务

jobClass - job类