springboot中多线程的使用

在Spring Boot中使用多线程，你可以通过以下两种常见方式实现：

1. 使用@Async注解：

   在Spring Boot中，你可以使用@Async注解来创建异步方法，这些方法将在独立的线程中运行。首先，需要在启动类上添加@EnableAsync注解来启用异步支持。

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableAsync;
 
@SpringBootApplication
@EnableAsync
public class AsyncApplication {
    public static void main(String[] args) {
        SpringApplication.run(AsyncApplication.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());
    }
}

在调用异步方法时，Spring会将其在后台的一个独立线程中执行。

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 asyncMethod() {
        asyncService.executeAsyncTask();
        return "Async task started";
    }
}

2. 使用ThreadPoolTaskExecutor自定义线程池：

   你还可以创建自定义的线程池，并使用ThreadPoolTaskExecutor来执行异步任务。

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 
import java.util.concurrent.Executor;
 
@Configuration
@EnableAsync
public class AsyncConfig {
 
    @Bean(name = "threadPoolTaskExecutor")
    public Executor threadPoolTaskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(10);
        executor.setMaxPoolSize(20);
        executor.setQueueCapacity(500);
        executor.initialize();
        return executor;
    }
}

然后，你可以在服务类中使用@Async("threadPoolTaskExecutor")来指定使用自定义的线程池。

import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
 
@Service
public class AsyncService {
 
    @Async("threadPoolTaskExecutor")
    public void exec