任务加载器

public interface ScheduleTaskService {

    /**
     * 获取即将被调度的任务
     * @return 调度任务集合
     */
    ScheduleTask get(Long taskId);

    /**
     * 从数据库获取启动状态的全部任务
     * @return 任务池中存在的全部任务
     */
    Collection<ScheduleTask> loadTask();
}

@Service
public class OpenJobServiceImpl extends ServiceImpl<OpenJobMapper, OpenJobDO> implements OpenJobService, ScheduleTaskService {

    private final TimeWheel timeWheel;
    private final OpenJobMapper openJobMapper;
    private final OpenJobClientService openJobClientService;
    private final ScheduleTaskExecutor scheduleTaskExecutor;

    public OpenJobServiceImpl(TimeWheel timeWheel,
                              OpenJobMapper openJobMapper,
                              OpenJobClientService openJobClientService,
                              ScheduleTaskExecutor scheduleTaskExecutor) {
        this.timeWheel = timeWheel;
        this.openJobClientService = openJobClientService;
        this.openJobMapper = openJobMapper;
        this.scheduleTaskExecutor = scheduleTaskExecutor;
    }

    //~~~

    @Override
    public ScheduleTask get(Long id) {
        OpenJobDO openJobDO = openJobMapper.selectById(id);
        if (CommonStatusEnum.of(openJobDO.getStatus()) == CommonStatusEnum.NO){
            return null;
        }
        return createScheduleTask(openJobDO);
    }

    @Override
    public List<ScheduleTask> loadTask() {
        List<OpenJobDO> scheduleTasks = openJobMapper.queryStartJob();
        if (CollectionUtils.isEmpty(scheduleTasks)){
            return Collections.emptyList();
        }
        return scheduleTasks.stream().map(this::createScheduleTask).collect(Collectors.toList());
    }

    //~~~
}