如何从XML Spring调度配置转到注释/代码配置？

Question

我正在尝试将以下Spring任务xml配置转换为纯粹基于代码/注释的版本：

<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一样简单。

但是，我看不到任何可以实际实例化调度程序的地方。@EnableScheduling（http://docs.spring.io/spring/docs/current/javadoc-
api/org/springframework/scheduling/annotation/EnableScheduling.html
）的Javadoc
显示了如何插入自己创建的Executor，尽管我不确定应该是哪个类（我仍然希望能够控制池大小，队列容量和拒绝策略）。它还显示了如何使用configureTasks重写计划我的createPartitions方法。但是，我希望能够命名我的调度程序（以便我可以识别其线程）并控制其池大小。

所以，我想知道这些事情：

1）我可以使用哪个类来设置XML的执行程序字段？

2）有没有一种方法可以创建一个调度程序实例，我可以控制它的名称和池大小？

Answer 1

退房的类型AsyncConfigurer，AsyncConfigurerSupport和SchedulingConfigurer。它们是帮助程序类型，您可以使用它们来@Configuration通过异步/调度配置来增强您的课程。

在所有这些代码以及的javadoc中@EnabledAsync，您将找到设置异步/计划@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。