Как перейти от конфигурации XML Spring к конфигурации аннотации/кода?

Я пытаюсь преобразовать следующую конфигурацию x7 для Spring задачи в чисто версию на основе кода/аннотации:

<task:executor id="xyz.executor"
    pool-size="${xyz.job.executor.pool.size:1-40}"
    queue-capacity="${xyz.job.executor.queue.capacity:0}"
    rejection-policy="CALLER_RUNS"/>

<task:scheduler id="xyz.scheduler" pool size="${xyz.job.scheduler.pool.size:4}"  />

<task:annotation-driven executor="xyz.executor" scheduler="xyz.scheduler" />

<bean id='xyzProcessor' class="xyz.queueing.QueueProcessor" /> 

<task:scheduled-tasks scheduler="xyz.scheduler" >
    <task:scheduled ref="partitioner" method="createPartitions" cron="${xyz.job.partitioner.interval:0 0 3 * * *}" />
</task:scheduled-tasks>

В спецификации Spring, 28.4.1 (http://docs.spring.io/spring/docs/current/spring-framework-reference/html/scheduling.html), они говорят, что перейти от XML следующим образом:

<task:annotation-driven executor="myExecutor" scheduler="myScheduler"/>
<task:executor id="myExecutor" pool-size="5"/>
<task:scheduler id="myScheduler" pool-size="10"/>

для конфигурации кода так же просто, как включение @EnableScheduling и/или @EnableAsync.

Однако я не вижу нигде, где я могу создать экземпляр планировщика. Javadoc для @EnableScheduling (http://docs.spring.io/spring/docs/current/javadoc-api/org/springframework/scheduling/annotation/EnableScheduling.html) показывает, как я могу подключиться к своему собственному созданному Executor, хотя я не совсем уверен, какой класс это должно быть (я все еще хочу иметь возможность контролировать размер пула, емкость очереди и политику отклонения). Он также показывает, как я могу запланировать мой метод createPartitions с помощью переопределения configureTasks. Тем не менее, я хотел бы иметь возможность назвать мой планировщик (чтобы я мог идентифицировать его потоки) и контролировать его размер пула.

Итак, я хочу знать эти вещи:

1) Какой класс я могу использовать для установки полей исполнителя, которые есть в XML?

2) Есть ли способ создать экземпляр планировщика, чтобы я мог управлять именем и размером пула?

Ответ 1

Проверьте типы AsyncConfigurer, AsyncConfigurerSupport и SchedulingConfigurer. Они являются вспомогательными типами, которые вы можете использовать для улучшения вашего класса @Configuration с настройками async/scheduling.

Во всех них и javadoc @EnabledAsync вы найдете все методы настройки, необходимые для настройки асинхронизации /scheduling @Configuration.

Приведенный пример приравнивает

 @Configuration
 @EnableAsync
 public class AppConfig implements AsyncConfigurer {

     @Bean
     public MyAsyncBean asyncBean() {
         return new MyAsyncBean();
     }

     @Override
     public Executor getAsyncExecutor() {
         ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
         executor.setCorePoolSize(7);
         executor.setMaxPoolSize(42);
         executor.setQueueCapacity(11);
         executor.setThreadNamePrefix("MyExecutor-");
         executor.initialize();
         return executor;
     }

     @Override
     public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
         return new MyAsyncUncaughtExceptionHandler();
     }
 }

с

 <beans>
     <task:annotation-driven executor="myExecutor" exception-handler="exceptionHandler"/>
     <task:executor id="myExecutor" pool-size="7-42" queue-capacity="11"/>
     <bean id="asyncBean" class="com.foo.MyAsyncBean"/>
     <bean id="exceptionHandler" class="com.foo.MyAsyncUncaughtExceptionHandler"/>
 </beans>

SchedulingConfigurer имеет аналогичную настройку для task:scheduler.

Ответ 2

Если вам нужен более мелкозернистый элемент управления, вы можете дополнительно реализовать интерфейсы SchedulingConfigurer и/или AsyncConfigurer.

Как утверждают,

Также обратите внимание на пулы,

@Configuration
@EnableScheduling
public class CronConfig implements SchedulingConfigurer{

    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
         taskRegistrar.setScheduler(taskExecutor());    
    }


     @Bean(destroyMethod="shutdown")
     public Executor taskExecutor() {
         return Executors.newScheduledThreadPool(10);
     }

}

И для Asyncs,

@Configuration
@EnableAsync
public class AsyncConfig implements AsyncConfigurer {

    @Override
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(5);
        executor.setMaxPoolSize(10);
        executor.setQueueCapacity(100);
        executor.initialize();
        return executor;
    }

    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        return new SimpleAsyncUncaughtExceptionHandler();
    }
}

Обратите внимание, что @EnableAsync и @EnableScheduling должны быть там, чтобы это работало.