Springboot-2.1.3：使用@Async使用PostalableFuture Aren调用并行方法在不同线程中调用

Question

下面是我的代码，试图并行化4种方法调用，因为每种方法彼此独立并执行了一些内存密集的统计操作。

@EnableAsync
@Configuration
public class Config {
   
    @Bean(name = "threadPoolTaskExecutor")
    public Executor threadPoolTaskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();        
        executor.initialize();
        return executor;
    }
}

class OrderStatsService{

    public CumulativeStats compute() {
        log.info("CumulativeResult compute started at " + System.currentTimeMillis() + ", Current Thread Name: " + Thread.currentThread().getName() + ", Current Thread ID: " + Thread.currentThread().getId());
        List<Order> orders = getOrders();// API Call to fetch large set of orders size could be around 100k
        
        CumulativeResult cumulativeResult = new CumulativeResult();

        CompletableFuture<Long> stats1 = getStats1(orders);
        CompletableFuture<List<String>> result2 = getStats2(orders);
        CompletableFuture<Double> result3 = getStats3(orders);
        CompletableFuture<Map<String,String>> result4 = getStats4(orders);

        cumulativeResult.setStats1(stats1);
        cumulativeResult.setStats2(stats2);
        cumulativeResult.setStats3(stats3);
        cumulativeResult.setStats4(stats4);
        return cumulativeResult;
    }
    
    @Async("threadPoolTaskExecutor")
    public CompletableFuture<Long> getStats1(var orders) {
    log.info("getStats1 started at " + System.currentTimeMillis() + ", Current Thread Name: " + Thread.currentThread().getName() + ", Current Thread ID: " + Thread.currentThread().getId());
        //computes some stats
    }

    @Async("threadPoolTaskExecutor")
    public CompletableFuture<List<String>> getStats2(var orders) {
    log.info("getStats2 started at " + System.currentTimeMillis() + ", Current Thread Name: " + Thread.currentThread().getName() + ", Current Thread ID: " + Thread.currentThread().getId());
        //computes some stats
    }

    @Async("threadPoolTaskExecutor")
    public CompletableFuture<Double>  getStats3(var> orders) {
    log.info("getStats3 started at " + System.currentTimeMillis() + ", Current Thread Name: " + Thread.currentThread().getName() + ", Current Thread ID: " + Thread.currentThread().getId());
        //computes some stats
    }

    @Async("threadPoolTaskExecutor")
    public CompletableFuture<Map<String,String>> getStats4(var orders) {
    log.info("getStats4 started at " + System.currentTimeMillis() + ", Current Thread Name: " + Thread.currentThread().getName() + ", Current Thread ID: " + Thread.currentThread().getId());
        //computes some stats
    }

}

我得到了预期的结果，但注意到正在调用Compute（）的主线程执行其他4种方法getStats1，getStats2 ，getStats3，getStats4方法。

CumulativeResult compute started at 1655783237437, Current Thread Name: http-nio-8080-exec-1, Current Thread ID: 28
getStats1 started at 1655783238022, Current Thread Name: http-nio-8080-exec-1, Current Thread ID: 28
getStats2 started at 1655783238024, Current Thread Name: http-nio-8080-exec-1, Current Thread ID: 28
getStats3 started at 1655783463062, Current Thread Name: http-nio-8080-exec-1, Current Thread ID: 28
getStats4 started at 1655783238085, Current Thread Name: http-nio-8080-exec-1, Current Thread ID: 28

我以为当我们使用完整的future @ASYNC带有@enableasync配置这些方法将被分配一个新线程以执行其执行，请有人可以说明这是预期的行为是否是为了平行方法调用？我的配置有什么问题吗？或者，如果这是预期的行为，当我们执行呼叫者方法和同一线程中的async时，如何实现并行性？

Answer 1

所需的更改可以在代码中完成。

步骤1：执行多线程的第一步是正确设置线程池配置。

首先设置线程

@Configuration
@EnableAsync
public class ThreadPoolConfiguration {

@Bean(name = "taskExecutor")
public ThreadPoolTaskExecutor threadPoolTaskExecutor() {
    ThreadPoolTaskExecutor threadPoolTaskExecutor = new ThreadPoolTaskExecutor();
    threadPoolTaskExecutor.setThreadNamePrefix("thread-");
    threadPoolTaskExecutor.setCorePoolSize(100);
    threadPoolTaskExecutor.setMaxPoolSize(120);
    threadPoolTaskExecutor.setQueueCapacity(100000);
    threadPoolTaskExecutor.initialize();
    return threadPoolTaskExecutor;
}

这是一个示例，说明了如何使用@ASYNC注释

步骤2： ，让我们介绍规则。

• @Async注释 - 必须仅应用于公共方法。
• @Async的自我发电将无法使用，这意味着从同一类中调用异步方法将无法使用。

有关@Async 您可以通过

解决方案：

• 将所有方法与@Async保持在不同的服务中，您可以
  从 orderstatsservice
• 又可以做的一件事是从控制器和所有
  @Async方法可以保存在服务类中。
• 标记您使用bean名称的注释，例如@Async（“ taskexecutor”）

哪种方式都适合您。

Answer 2

您应该设置线程池大小以控制线程计数：

final ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(2);
executor.setMaxPoolSize(2);
executor.setQueueCapacity(100);
executor.setThreadNamePrefix("CarThread-");

使用完整的图中的春季启动中的多线程

Answer 3

我建议检查一些事实：

1. 您的OrderstatsService class static static 是否bean由Spring管理？
2. @ASYNC bean的方法必须直接从其呼叫者中调用。您在OrderstatsService（bean - 是否已经完成此操作）中正在调用non-@async方法，然后调用@Async方法。根据我的经验，这不会给您预期的行为。

如果我是个虚拟愚蠢的愚蠢，请随时纠正我。