在Spring Boot中，你可以使用@EnableAsync注解和@Async注解来配置和使用异步线程池。以下是一个简单的例子：
- 首先，在Spring Boot的主类或配置类上添加
@EnableAsync注解来启用异步支持。
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableAsync;
@SpringBootApplication
@EnableAsync
public class AsyncThreadPoolApplication {
public static void main(String[] args) {
SpringApplication.run(AsyncThreadPoolApplication.class, args);
}
}- 然后，创建一个异步任务的服务类，并使用
@Async注解标记异步方法。
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
@Service
public class AsyncService {
@Async
public void executeAsyncTask() {
// 这里是异步执行的任务
System.out.println("异步执行的任务: " + Thread.currentThread().getName());
}
}- 在你的控制器或者其他服务中调用异步服务。
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class AsyncController {
@Autowired
private AsyncService asyncService;
@GetMapping("/async")
public String startAsyncTask() {
asyncService.executeAsyncTask();
return "异步任务已启动";
}
}当你访问/async端点时，executeAsyncTask方法将会在异步线程池中执行，而不会阻塞主线程。
注意：默认情况下，Spring会为@Async注解的方法创建一个线程池。如果你需要自定义线程池的配置，你可以通过@Configuration类配置一个Executor。
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.context.annotation.Bean;
import java.util.concurrent.Executor;
@Configuration
@EnableAsync
public class AsyncConfig implements AsyncConfigurer {
@Override
@Bean
public Executor getAsync