在Java中运行连续批处理

Timer timer = new Timer();
timer.schedule(new TimerTask() {
    @Override
    public void run() {
        // 在这里执行任务
    }
}, 0, 5000);

ScheduledExecutorService executor = Executors.newScheduledThreadPool(1);
executor.scheduleAtFixedRate(() -> {
    // 在这里执行任务
}, 0, 5, TimeUnit.SECONDS);

JobDetail job = JobBuilder.newJob(MyJob.class)
    .withIdentity("myJob", "group1")
    .build();

SimpleScheduleBuilder scheduleBuilder = SimpleScheduleBuilder.simpleSchedule()
    .withIntervalInSeconds(5)
    .repeatForever();

Trigger trigger = TriggerBuilder.newTrigger()
    .forJob(job)
    .withIdentity("myTrigger", "group1")
    .startNow()
    .withSchedule(scheduleBuilder)
    .build();

Scheduler scheduler = new StdSchedulerFactory().getScheduler();
scheduler.start();
scheduler.scheduleJob(job, trigger);