Spring Boot：我们可以为每个请求设置单独的线程池吗？

Question

我在应用程序中使用Spring Boot@async实现了一个方法的异步执行。我有一个自定义线程池有20个线程。在调用async方法30次的for循环中。

每个单独的请求都是异步执行的，但是当我从浏览器向API同时发出两个不同的请求时，第一个请求是执行的，然后是第二个请求。不能同时执行同一方法的两个请求。

我们能为每个单独的请求有单独的线程池吗。或者我们可以使每个请求的执行独立于其他请求处理的任何方式。

这是我的代码示例。

@SpringBootApplication
@EnableAsync
public class AppBootStrap
{
  public static void main(String[] args)
  {
    SpringApplication.run(AppBootStrap.class, args);
  }

  @Bean
  public AsyncTaskService asyncTaskService() {
    return new AsyncTaskService();
  }

  @Bean(name="customExecutor")
  public Executor taskExecutor() {
    ThreadPoolTaskExecutor poolExecutor = new ThreadPoolTaskExecutor();
    poolExecutor.setCorePoolSize(10);
    poolExecutor.setMaxPoolSize(20);
    poolExecutor.setThreadNamePrefix("customPoolExecutor");
    poolExecutor.initialize();
    return poolExecutor;
  }
}

**Controller Class:**

@RestController
public class TaskController
{
  @Autowired
  private TaskService taskService;

 @RequestMapping("/performAction")
 public void performAction() {
    taskService.performAction();
 }
}

**Service class**

@Service
public class TaskService
{
  @Autowired
  private AsyncTaskService asyncTaskService;

  public void performAction()
  {
    for(int i = 0; i < 30; i++) {
        asyncTaskService.greetings(i);
    }
  }
}

**Async Method Class**

public class AsyncTaskService
{
  @Async
  public void greetings(Integer i)
  {
    try
    {
        Thread.sleep(500 * (i + 10));
    }
    catch (InterruptedException e)
    {
        e.printStackTrace();
    }
    System.out.println("Welcome to Async Service: " + i);
  }
}

Answer 1

我认为问题在于customExecutor bean是一个单例。这意味着当第二个请求尝试使用这个bean时，它会发现thred池中的所有线程都很忙。您可以尝试通过使用@scope（“prototype”）注释来使customExecutor bean不是单例的，每当请求这种类型的bean时，这将导致实例化一个新的bean。