探寻用户自定义定时任务的实践方案(6)

任务执行

任务调度提交的任务给线程池处理，执行前后根据任务定义对任务做一些通用处理（黄色框部分），具体的执行业务逻辑交给接口 LocalWork 实现类的 execute() 方法处理。

/** * description: 辅助来完成默认的localWork方法 */public class TaskWorkUtils { static void helpRun(TaskWork localWork, ScheduleTask scheduleTask) { //部分伪代码如下 } }//是否任务有执行过boolean executed = false;TaskScheduleRecord record = null;Date executeDate = new Date();try { //根据需要决定是否获取锁后执行（redisLock，zkLock，dbLock都可以，保证任务唯一执行） String lockName = localWork.getClass().getSimpleName() scheduleTask.getLocalScheduleDefine().getBusId(); //获取不到锁return //获取到执行下面逻辑 record = ExceptionUtils.doFunLogE(() -> { TaskScheduleRecord newRecord = buildRecord(scheduleTask, executeDate); newRecord.setId(taskRecordService.save(newRecord)); return newRecord; }); //如果不能保存成功,表示出现了数据库异常,相应状态不能存取,则直接返回,不再执行 if (record == null) { return; } executed = true; localWork.execute(record);} catch (Throwable throwable) { log.error("执行任务时出现异常信息:{}", throwable.getMessage(), throwable); e = throwable;} finally { //释放锁：