Spring async ConcurrentTaskExecutor 没有真正正常工作？

Question

这是我第一次在 Spring Boot 中使用 Async。这是我的项目的结构。

我有以下ExecutorConfig课程

@Configuration
@EnableAsync
public class ExecutorConfig {
    @Bean(name = "ConcurrentTaskExecutor")
    public Executor getAsyncExecutor() {
        return new ConcurrentTaskExecutor(Executors.newFixedThreadPool(10));
    }
}

以下类将使用@Scheduled 调用

@Component
public class RealtyTracCountyScraper {

    @Autowired
    StateScrapeQueueRepository stateScrapeQueueRepository;

    @Autowired
    CountyScrapeRepository countyScrapeRepository;

    @Autowired
    CountyScraper countyScraper;

    // @Scheduled(cron = "0 0 */3 * * *")
    @EventListener(ApplicationReadyEvent.class)
    public void scrapeCountyLinks() {
        System.out.println("Scrape county links ran!");
        try {
            List<String> stateLinks = stateScrapeQueueRepository.getStatesLinks("");

            for (int i = 0; i < stateLinks.size(); i++) {
                countyScraper.run(stateLinks.get(i));
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            System.out.println("---------------------");
        }
    }

}

和从上面的类调用的这个类（这是包含多线程方法的类）

@Component
public class CountyScraper implements AsyncConfigurer {

    @Autowired
    StateScrapeQueueRepository stateScrapeQueueRepository;

    @Autowired
    CountyScrapeRepository countyScrapeRepository;

    @Async("ConcurrentTaskExecutor")
    public void run(String stateLink) {
        System.out.println("New thread");
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("Done");

    }
}

尽管我在ExecutorConfig课堂上设置了 10 个固定线程，但看起来一次只有一个线程有效。知道我做错了什么吗？

Answer 1

我想您的代码中有些地方并不完全正确。

1. 您的组件实现 AsyncConfigurer
2. 你没有 @EnableScheduling

你CountyScraper实现了AsyncConfigurer接口。导致2个可能的问题。第一个是使用基于接口的代理而不是基于类的代理的默认值和用法来配置异步处理。因此消除了@Async. 虽然后者似乎并非如此，但人们可能永远不会知道。

在AsyncConfigurer实际上应该由你来实现ExecutorConfig。

@Configuration
@EnableAsync
@EnableScheduling
public class ExecutorConfig implements AsyncConfigurer {

    public Executor getAsyncExecutor() {
        return taskExecutor();
    }

    @Bean
    public ThreadPoolTaskExecutor taskExecutor() {
        ThreadPoolTaskExecutor taskExecutor = new TaskExecutor();
        taskExecutor.setCorePoolSize(10);
        return taskExecutor;
    }
}

这将配置Executor用于异步处理的默认值。而不是 aConcurrentTaskExecutor我用了ThreadPoolTaskExecutor代替。后者允许更多的配置，并且会在 Spring Boot 关闭时很好地清理线程。

提示：如果您使用的是 Spring Boot 2.1，您实际上可以放弃 的配置TaskExecutor并将其替换为仅配置。

现在您可以使用简单@Async而不是显式命名执行器（现在会失败，因为它的命名不同）。

spring.task.execution.pool.core-size=10 # Default is 8

你的配置然后变成

@Configuration
@EnableAsync
@EnableScheduling
public class ExecutorConfig {}