не может автоматически подключить JobLauncher, всегда возвращает ноль

Question

я пытался связать каждую работу с потоком, чтобы я мог запускать несколько работ одновременно с разными значениями cron, но jobLauncher всегда получает значение null.

я пытался создать jobLauncher в качестве компонента в классе конфигурациино это никогда не работало.

@Component
public class MyTask extends Thread {

   @Autowired
   private ApplicationContext context;

   @Autowired
   private JobLauncher jobLauncher;

   @Autowired
   private Batchconfig config;


   public void run() {
     Jobs job = Scheduler.listLinked.get(this);
     if (job != null && job.isState()) {
        JobParameters jobParameters = new JobParametersBuilder().addLong("time", System.currentTimeMillis())
                .addString("param", job.getParam()).toJobParameters();
        try {
            JobExecution jobExecution = jobLauncher.run(config.execute(job.getName()), jobParameters);
            System.out.println("Job's Status:::" + jobExecution.getStatus());
        } catch (JobExecutionAlreadyRunningException | JobRestartException | JobInstanceAlreadyCompleteException
                | JobParametersInvalidException e) {
            e.printStackTrace();
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
  }

}

@Component
public class Scheduler implements SchedulingConfigurer {


   @Override
   public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
     set();
     for (Jobs j : list) {
        MyTask th = new MyTask();
        listLinkedInverse.put(j, th);
        listLinked.put(th, j);
        taskRegistrar.addCronTask(th, j.getCron());
     }
   }

}

Исключение:

java.lang.NullPointerException
   at com.generator.config.batch.scheduler.MyTask.run(MyTask.java:39)
   at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54)
   at org.springframework.scheduling.concurrent.ReschedulingRunnable.run(ReschedulingRunnable.java:93)
   at java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
   at java.util.concurrent.FutureTask.run(Unknown Source)
   at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(Unknown Source)
   at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown Source)
   at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
   at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
   at java.lang.Thread.run(Unknown Source)

Answer 1

Я попробовал это решение, и оно сработало

@Component
public class Scheduler {
        @Autowired
private ApplicationContext context;


@Autowired
public static JobLauncher jobLauncher;

@Autowired
public static Batchconfig config;

@Autowired
private JobService jobService;

private final ScheduledExecutorService scheduler =
         Executors.newScheduledThreadPool(1);

public static Map<ScheduledFuture<Jobs>, Jobs> listLinked = new HashMap<>();
public static Map<Jobs, ScheduledFuture<Jobs>> listLinkedInverse = new HashMap<>();
List<Jobs> list;

@PostConstruct
public void init() {
    list = jobService.findAll();
    for (Jobs j : list) {
        if(j.isState()) {
            MyTask th = new MyTask(j);
            context.getAutowireCapableBeanFactory().autowireBean(th);
            ScheduledFuture<Jobs> jobHandler = (ScheduledFuture<Jobs>) scheduler.scheduleAtFixedRate(th, 0, 2, TimeUnit.SECONDS);
            listLinkedInverse.put(j, jobHandler);
            listLinked.put(jobHandler, j);
        }

    }
}

public void launchJob(Jobs myJob){
    MyTask th = new MyTask(myJob);
    context.getAutowireCapableBeanFactory().autowireBean(th);
    ScheduledFuture<Jobs> jobHandler = (ScheduledFuture<Jobs>) scheduler.scheduleAtFixedRate(th, 0, 2, TimeUnit.SECONDS);
    listLinkedInverse.put(myJob, jobHandler);
    listLinked.put(jobHandler, myJob);

}

public void cancelJob(Jobs j) {
    listLinkedInverse.get(j).cancel(true);
    listLinked.remove(listLinkedInverse.get(j));
    listLinkedInverse.remove(j);


}
}



@Component
public class MyTask extends Thread {

    @Autowired
    private JobLauncher jobLauncher;

    private Jobs job;

    @Autowired
    private Batchconfig config;

    public MyTask() {
    }

    public MyTask(Jobs job) {
        this.job = job;
    }
    public void run() {
            JobParameters jobParameters = new JobParametersBuilder().addLong("time", System.currentTimeMillis())
                    .addString("param", job.getParam()).toJobParameters();
            try {
                JobExecution jobExecution = jobLauncher.run(config.execute(job.getName()), jobParameters);
                System.out.println("Job's Status:::" + jobExecution.getStatus());
            } catch (JobExecutionAlreadyRunningException | JobRestartException | JobInstanceAlreadyCompleteException
                    | JobParametersInvalidException e) {
                e.printStackTrace();
            } catch (Exception e) {
                e.printStackTrace();
            }
    }

}

Answer 2

Экземпляр MyTask создается вручную (в MyTask th = new MyTask()), а не Spring, следовательно, внедрение зависимостей не будет выполнено, и автонастройка JobLauncher будет нулевой.

Вам необходимо создатьbean-компонент типа MyTask (чтобы его зависимости корректно вводились), а затем внедрите его в свой класс Scheduler в качестве соавтора.

В качестве примечания: это не идеальный способ одновременного запуска нескольких заданий. ,Вы создаете JobLauncher для потока, который, в свою очередь, использует SyncTaskExecutor по умолчанию. Что вы можете сделать, это создать один JobLauncher и настроить его с помощью пула потоков для одновременного запуска заданий, например:

@Bean
public JobLauncher jobLauncher() {
   SimpleJobLauncher jobLauncher = new SimpleJobLauncher();
   jobLauncher.setJobRepository(jobRepository());
   jobLauncher.setTaskExecutor(new SimpleAsyncTaskExecutor()); // or use ThreadPoolTaskExecutor
   jobLauncher.afterPropertiesSet();
   return jobLauncher;
}

Более подробную информацию вы можете найти в Настройка JobLauncher раздел справочной документации.