java类org.springframework.scheduling.annotation.Scheduled的实例源码

/**
 * herlaad.
 */
@Scheduled(fixedDelayString = "${brp.levering.admhndpublicatie.delay:500}")
public void herlaad() {
    LOGGER.trace("start lever batch administratieve handelingen voor levering");
    admhndProducerVoorLeveringService.produceerHandelingenVoorLevering();
    LOGGER.trace("einde lever batch administratieve handelingen voor levering");
}

@Scheduled(fixedRate = 5000)
public void run() {
    String time = LocalTime.now().format(TIME_FORMAT);

    log.info("Time broadcast: {}", time);
    broker.convertAndSend("/topic/greetings", new Greeting("Current time is " + time));
}

@Scheduled(fixedRate = SCENARIO_CHECK_INTERVAL)
public void checkAndReleaseScenariosOnTime() {

    for(Map.Entry<String, ScenarioWrapper> entry: runningScenariosMap.entrySet()) {
        String agentName = entry.getKey();
        ScenarioWrapper scw = entry.getValue();
        if (scw.getRemainingSeconds() <= 0) {
            scenarioService.disableScenario(agentName, scw.getScenario().getId());
            runningScenariosMap.remove(agentName);
            log.info("Scenario '" + scw.getScenario().getName() + "' is finished. " + scw.toString());
        }
    }
}

@Scheduled(cron="0 0/1 * * * ?")
public void instagramTimeScheduler() {
    logger.info("正在连接Instagram获取最新Feed 。。。");
    GemInsPicture gemInsPicture = new GemInsPicture();
    gemInsPicture.flushInstagram();
    logger.info("断开连接Instagram 。。。");
}

@Scheduled(fixedRate = 30 * 1000)
public boolean DelOutTimeSqlLog() {
    if (_sqlMap.size() > 0) {
        Map<String, ArrayList<Integer>> delSqlMap = new Hashtable<>();
        for (Map.Entry<String, Map<Long, SqlStatisticStruct>> ent : _sqlMap.entrySet()) {
            ArrayList<Long> delList = new ArrayList<>();
            if (ent.getValue().size() > 0) {
                for (Map.Entry<Long, SqlStatisticStruct> hourent : ent.getValue().entrySet()) {
                    if (hourent.getKey() >= DateTimeHelper.getCurrentTime() - fieryConfig.getKeepdataday() * 86400) {
                        continue;
                    }
                    delList.add(hourent.getKey());
                    //_sqlMap.get(ent.getKey()).remove(hourent.getKey());
                    //log.info("del out time sql log:" + ent.getKey() + ",log create_time:" + DateTimeHelper.TimeStamp2Date(hourent.getKey().toString(), "yyyy-MM-dd HH:mm:ss"));
                }
            }
            /*if (_sqlMap.get(ent.getKey()).size() == 0) {
                    _sqlMap.remove(ent.getKey());
            }*/
        }
        for (Map.Entry<String, ArrayList<Integer>> sqlent : delSqlMap.entrySet()) {
            for (Integer key : sqlent.getValue()) {
                _sqlMap.get(sqlent.getKey()).remove(key);
                log.info("del out time sql log:" + sqlent.getKey() + ",log create_time:" + DateTimeHelper
                        .TimeStamp2Date(key.toString(), "yyyy-MM-dd HH:mm:ss"));
            }
            if (_sqlMap.get(sqlent.getKey()).size() == 0) {
                _sqlMap.remove(sqlent.getKey());
            }
        }
    }
    return true;
}

@Scheduled(fixedDelay = 7000)
public void sendNewApoyo() {
    String comentarioJSON = "";
    comentario = randomGenerator.newComentario();
    comentario.setTexto("");

    try {
        comentarioJSON = mapper.writeValueAsString(comentario);
        send("apoyos", comentarioJSON);
    } catch (JsonProcessingException e) {
        e.printStackTrace();
    }
}

@Scheduled(fixedRateString = "${github.job.fixed.delay.seconds:60}000")
public void runGithubJob() {

    SimpleDateFormat format = new SimpleDateFormat("M-dd-yy hh:mm:ss");
    String startDateTime = format.format(new Date());

    JobParameters jobParameters =
            new JobParametersBuilder()
                    .addLong("time", System.currentTimeMillis()).toJobParameters();

    try {
        logger.info("");
        logger.info("STARTING GITHUB BATCH JOB : " + startDateTime);
        JobExecution execution = jobLauncher.run(githubJob, jobParameters);
        logger.info("JOB STATUS  : " + execution.getStatus());
    } catch (Exception e) {
        e.printStackTrace();
        logger.info("JOB FAILED!!!");
    }

}

@Override
@Transactional(propagation = Propagation.NEVER)
@Scheduled(fixedDelay = 300 * 1000)
public void checkTimeoutTask() {
    if (!taskConfig.isEnableCmdExecTimeoutTask()) {
        return;
    }
    LOGGER.traceMarker("checkTimeoutTask", "start");

    // find all running status cmd
    List<Cmd> workingCmdList = cmdService.listWorkingCmd(null);

    for (Cmd cmd : workingCmdList) {
        if (cmd.getType() != CmdType.RUN_SHELL || !cmd.isCurrent()) {
            continue;
        }

        if (DateUtil.isTimeOut(cmd.getCreatedDate(), ZonedDateTime.now(), cmd.getTimeout())) {
            try {
                Cmd killCmd = cmdService.create(new CmdInfo(cmd.getAgentPath(), CmdType.KILL, null));
                dispatch(killCmd);
                LOGGER.traceMarker("checkTimeoutTask", "Send KILL for timeout cmd %s", cmd);

                CmdStatusItem statusItem = new CmdStatusItem(cmd.getId(), CmdStatus.TIMEOUT_KILL, null, true, true);
                cmdService.updateStatus(statusItem, false);
            } catch (Throwable e) {
                LOGGER.warn(e.getMessage());
            }
        }
    }

    LOGGER.traceMarker("checkTimeoutTask", "end");
}

@Scheduled(cron = "${update.allergen.cron}")
public void update() {
    log.info("Starting allergen update");
    List<Allergen> allergens = scraper.scrape();
    if (!allergens.isEmpty()) {
        List<Allergen> oldAllergens = repo.findAll();
        log.info("Replacing {} old allergens with {} new ones", oldAllergens.size(), allergens.size());
        repo.delete(oldAllergens);
        repo.save(allergens);
        log.info("Finished allergen update");
    } else {
        log.info("No allergens found");
    }
}

/**
 * Persistent Token are used for providing automatic authentication, they should be automatically deleted after
 * 30 days.
 * <p>
 * This is scheduled to get fired everyday, at midnight.
 * </p>
 */
@Scheduled(cron = "0 0 0 * * ?")
public void removeOldPersistentTokens() {
    LocalDate now = LocalDate.now();
    persistentTokenRepository.findByTokenDateBefore(now.minusMonths(1)).forEach(token -> {
        log.debug("Deleting token {}", token.getSeries());
        persistentTokenRepository.delete(token);
    });
}