Spring Boot REST-对单个作业使用ThreadPoolTaskExecutor

Question

我加入了公司的一个新团队，我看到他们广泛使用“ThreadPoolTaskExecutor”。它基本上是前端的后端REST应用程序，它调用其他SOAP API并将结果返回给客户机--只是一个传递。99%的情况下，每个RESTendpoint只调用单个SOAP API，并将json格式的响应返回给客户机。然而，尽管这只是一个SOAP调用，但它们使用了“ThreadPoolTaskExecutor”并调用了.get（）阻塞方法。

@Configuration类上的ThreadPoolTaskExecutor@Bean:

@Bean(name=“soapAsyncExecutor")
@Qualifier("soapAsyncExecutor")
   public ThreadPoolTaskExecutor getSoapAsyncExecutor() {
    final ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    final ThreadFactory customThreadfactory = new ThreadFactoryBuilder()
        .setNameFormat(“SoapExecutor-%d")
        .setUncaughtExceptionHandler(uncaughtExceptionHandler())
        .setDaemon(true)
        .build();
    executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
    executor.setCorePoolSize(80);
    executor.setMaxPoolSize(200);
    executor.setQueueCapacity(80);
    executor.setKeepAliveSeconds(60);
    executor.setAllowCoreThreadTimeOut(true);
    executor.setThreadFactory(customThreadfactory);
    executor.afterPropertiesSet();
    return executor;
   }

@service上的代码：

@Async("soapAsyncExecutor")
@Override
public Future<OrderInfo> getOrderInfoAsync(final String orderId) {
    return new AsyncResult<OrderInfo>(this.getOrderInfo(orderId);
}

private OrderInfo getOrderInfo(final String orderId) {
    // return result from SOAP call which typically take 1 second
}

然后从上面的@RestController异步方法调用如下：

@GetMapping(value = "/order/{orderId}")
public OrderInfo getOrderInfo(@PathVariable("orderId") final String orderId) {
   OrderInfo orderInfo = orderService.getOrderInfoAsync(orderId).get();
   return orderInfo;
}

1. 主线程的官方状态是什么--“阻塞”还是“等待”？如果阻塞，那么对单个作业使用这样的“ThreadPoolTaskExecutor”是否有一点好处，因为它会使主线程阻塞？
2. 可以以任何方式对此代码进行调整以带来好处吗？或者在RestControllerendpoint内对单个作业使用异步编程没有意义吗？

Answer 1

主线程的官方状态是什么--“阻塞”还是“等待”？

被封锁了。

如果阻塞了，对单个作业使用这样的“ThreadPoolTaskExecutor”是否有一点好处，因为它会阻塞主线程？

这段代码可以以任何方式进行调整以带来好处吗？或者在RestControllerendpoint内对单个作业使用异步编程没有意义吗？

当然可以。这里有一个例子。这里还有一个。本质上，在您的场景中，只返回completablefuture就足够了，而不是调用.get()。