OnlyOneInAllScenarioRunner.java 文件源码

@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());
        }
    }
}