Рекурсивный вызов функции с задержкой по времени

Question

У меня есть веб-приложение, мне нужно запустить процесс backgroung, который попадет в веб-сервис, после получения ответа он будет ждать несколько секунд (скажем, 30), а затем снова попадет в службу. Данные ответа могут варьироваться от очень малых до очень больших, поэтому я не хочу вызывать processagain, пока не закончу обработку данных. Таким образом, это рекурсивный вызов с задержкой по времени. Как я собираюсь сделать это:

1. Добавить контекстListener в веб-приложение.

2. В контекстеIntialized() метод вызывает invokeWebService(), т. Е. Метод для обращения к веб-службе.

3. invokeWebService будет выглядеть как:

   invokeWebService() 
   { 
   
   //make request 
   
   //hit service 
   
   //get response 
   
   //process response 
   
   timeDelayInSeconds(30); 
   
   //recursive call 
   invokeWebService(); 
   
   } 
   

Pls. предлагаю ли я делать это правильно. Или идите с потоками или планировщиками. Pls. ответьте на примеры кода.

Answer 1

Вы можете использовать ScheduledExecutorService, which is part of the standard JDK since 1.5:

ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1); 
    Runnable r = new Runnable() { 

     @Override 
     public void run() { 
      invokeWebService(); 
     } 
    }; 

    scheduler.scheduleAtFixedRate(r, 0, 30, TimeUnit.SECONDS); 

Answer 2

Это не рекурсивно, но повторяется. У вас есть два выбора здесь:

• Используйте таймер и TimerTask с scheduleAtFixedRate
• Используйте Quartz с повторным графиком.

В кварце, вы можете создать повторяющееся расписание с этим кодом:

TriggerBuilder.newTrigger().withSchedule(SimpleScheduleBuilder.repeatSecondlyForever(30)) 
       .build() 

Answer 3

Из того, что я получаю, ожидая своего рода подразумевает повешение, что я не думаю, это хорошая идея. Я бы рекомендовал вам использовать что-то вроде Quartz и запустить свой метод в любой промежуток времени.

Кварц является полнофункциональным, открытым исходным кодом, работа службы планирования, которая может быть интегрирован с, или использоваться вдоль стороны практически любой Java EE или Java SE приложения

Учебники могут быть доступны here.

Как указано в here вы можете сделать что-то вроде этого:

JobDetail existingJobDetail = sched.getJobDetail(jobName, jobGroup); 
    if (existingJobDetail != null) { 
     List<JobExecutionContext> currentlyExecutingJobs = (List<JobExecutionContext>) sched.getCurrentlyExecutingJobs(); 
     for (JobExecutionContext jec : currentlyExecutingJobs) { 
      if(existingJobDetail.equals(jec.getJobDetail())) { 
       //String message = jobName + " is already running."; 
       //log.info(message); 
       //throw new JobExecutionException(message,false); 
      } 
     } 
     //sched.deleteJob(jobName, jobGroup); if you want to delete the scheduled but not-currently-running job 
    }