Spring靴。如何创建带注释的TaskExecutor？

Question

我在Spring Boot应用程序中使用应该异步运行的方法之一做了一个@Service类。因为我读的方法应该是@Async注释，而且我还必须运行一个TaskExecatorbean。但是在Spring手册中http://docs.spring.io/spring/docs/current/spring-framework-reference/html/scheduling.html我没有找到任何信息或示例，如何在没有XML配置的情况下使用注释运行TaskExec导师。有没有可能在Spring Boot中创建TaskExec导师bean而不使用XML，只使用注释？这里我的服务类：

@Service
public class CatalogPageServiceImpl implements CatalogPageService {

    @Override
    public void processPagesList(List<CatalogPage> catalogPageList) {
        for (CatalogPage catalogPage:catalogPageList){
            processPage(catalogPage);
        }
    }

    @Override
    @Async("locationPageExecutor")
    public void processPage(CatalogPage catalogPage) {
        System.out.println("print from Async method "+catalogPage.getUrl());
    }
}

Answer 1

更新：从Spring Boot 2.2开始，不需要通过代码创建ThreadPoolTaskExecutor，因为ThreadPoolTaskExecutor是默认值，可以使用前缀为Spring的属性完全配置。任务执行。

因此，以下步骤：

1. 在@配置-注释类中使用@EnableAsync，

属性示例：

spring.task.execution.pool.core-size=1
spring.task.execution.pool.max-size=20
spring.task.execution.pool.keep-alive=120s
spring.task.execution.pool.queue-capacity=1000
spring.task.execution.shutdown.await-termination=true
spring.task.execution.shutdown.await-termination-period=5m
spring.task.execution.thread-name-prefix=async-executor-
spring.task.execution.pool.allow-core-thread-timeout=false

如果需要更多的定制，还可以实现TaskExecutorCustomzer接口，例如（在kotlin中）：

@Component
class AsyncExecutorCustomizer : TaskExecutorCustomizer {
    override fun customize(taskExecutor: ThreadPoolTaskExecutor?) {
        taskExecutor?.let { executor ->
            executor.setRejectedExecutionHandler(ThreadPoolExecutor.CallerRunsPolicy())
        }
    }
}

Answer 2

首先–让我们回顾一下规则-@Async有两个限制：

• 它只能应用于公共方法
• 自调用——从同一个类中调用异步方法——将不起作用

因此，processPage（）方法应该在单独的类中

Answer 3

添加一个@Bean方法到Spring Boot应用程序类：

@SpringBootApplication
@EnableAsync
public class MySpringBootApp {

    @Bean
    public TaskExecutor taskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(5);
        executor.setMaxPoolSize(10);
        executor.setQueueCapacity(25);
        return executor;
    }

    public static void main(String[] args) {
        // ...
    }
}

请参阅Spring框架参考文档中基于Java的容器配置，了解如何使用Java配置而不是XML配置Spring。

（注意：你不需要添加@Configuration到类中，因为@SpringBootApplication已经包含了@Configuration）。