springboot线程的用法以及配置详解

男娘i 2024-03-17 10:57 49阅读 0赞

在 Spring Boot 中使用注解设置多线程，一般需要借助 \`@Async\` 注解和 \`ThreadPoolTaskExecutor\` 类。

首先，需要在 Spring Boot 应用程序的主类上添加 \`@EnableAsync\` 注解，该注解表示开启异步执行。

\`\`\`java  
@SpringBootApplication  
@EnableAsync  
public class MyApplication \{  
// ...  
\}  
\`\`\`

接着，在需要进行多线程执行的方法上添加 \`@Async\` 注解。该注解表示该方法会在单独的线程中异步执行。

\`\`\`java  
@Service  
public class MyService \{  
@Async  
public void doSomething() \{  
// ...  
\}  
\}  
\`\`\`

如果需要定制线程池的参数，可以使用 \`ThreadPoolTaskExecutor\` 类。可以在 Spring Boot 的配置文件中设置线程池的参数，也可以在代码中手动创建一个 \`ThreadPoolTaskExecutor\` 对象。

\`\`\`java  
@Configuration  
public class MyConfig \{  
@Bean  
public Executor myExecutor() \{  
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();  
executor.setCorePoolSize(10);  
executor.setMaxPoolSize(20);  
executor.setQueueCapacity(100);  
executor.setThreadNamePrefix("MyExecutor-");  
executor.initialize();  
return executor;  
\}  
\}  
\`\`\`

在上面的代码中，创建了一个名为 \`myExecutor\` 的线程池，设置了核心线程数为 10，最大线程数为 20，队列容量为 100，线程名称前缀为 \`MyExecutor-\`。

最后，在需要使用多线程的方法上，使用 \`@Async\` 注解并指定使用的线程池。

\`\`\`java  
@Service  
public class MyService \{  
@Async("myExecutor")  
public void doSomething() \{  
// ...  
\}  
\}  
\`\`\`

在上面的代码中，使用 \`@Async("myExecutor")\` 注解指定了使用名为 \`myExecutor\` 的线程池来执行该方法。

以上是使用注解设置多线程的一个示例，希望对你有所帮助。

下面是配置：

@Bean  
public Executor getAsyncExecutor() \{  
ThreadPoolTaskExecutor threadPool = new ThreadPoolTaskExecutor();  
//设置核心线程数  
threadPool.setCorePoolSize(Runtime.getRuntime().availableProcessors());  
//设置最大线程数  
threadPool.setMaxPoolSize(Runtime.getRuntime().availableProcessors()\*4);  
//线程池所使用的缓冲队列  
threadPool.setQueueCapacity(100000);  
//等待任务在关机时完成->表明等待所有线程执行完  
threadPool.setWaitForTasksToCompleteOnShutdown(true);  
// 等待时间 （默认为0，此时立即停止），并没等待xx秒后强制停止  
threadPool.setAwaitTerminationSeconds(60);  
// 设置线程活跃时间（秒）  
threadPool.setKeepAliveSeconds(60);  
// 线程名称前缀,不设置默认为方法名  
threadPool.setThreadNamePrefix("Async-");  
//拒绝策略  
threadPool.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());  
// 初始化线程  
threadPool.initialize();  
return threadPool;这些配置你都讲下

当使用 \`@Async\` 注解时，Spring Framework 提供了一些默认的线程池配置，但是你可以根据自己的需求自定义线程池，以更好地适应应用程序的性能和资源需求。这里是对上述代码的几个线程池配置的解释：

1. \`setCorePoolSize()\`：设置核心线程数。当提交一个任务时，如果当前线程数小于核心线程数，则创建新线程执行任务，即使其他空闲线程存在。如果当前线程数大于或等于核心线程数，则将任务放入工作队列。

2. \`setMaxPoolSize()\`：设置最大线程数。当工作队列已满时，创建新线程执行任务，但线程数不会超过最大线程数。如果设置的最大线程数小于或等于核心线程数，则核心线程数即为最大线程数。

3. \`setQueueCapacity()\`：设置线程池所使用的缓冲队列的容量。当任务提交时，如果线程池中的线程数已经达到核心线程数，那么任务会被加入到这个缓冲队列中。

4. \`setWaitForTasksToCompleteOnShutdown()\`：设置线程池在关机时是否等待所有任务完成。如果设置为 true，那么在关闭时会等待所有任务完成之后才会关闭线程池。

5. \`setAwaitTerminationSeconds()\`：设置线程池关闭的等待时间。如果设置了 \`setWaitForTasksToCompleteOnShutdown(true)\`，那么在关闭线程池之前会等待所有任务完成。如果在等待的时间内还有任务没有完成，那么这些任务将被强制停止。

6. \`setKeepAliveSeconds()\`：设置线程的活跃时间。如果线程超过这个时间还没有任务需要执行，那么线程将被关闭。

7. \`setThreadNamePrefix()\`：设置线程名称前缀。如果不设置，默认为方法名。

8. \`setRejectedExecutionHandler()\`：设置拒绝策略。当线程池中的线程数已经达到最大线程数，并且工作队列已满时，新的任务将被拒绝执行。可以设置不同的拒绝策略来处理这种情况。例如，\`ThreadPoolExecutor.CallerRunsPolicy()\` 表示当线程池无法处理任务时，将该任务交给当前线程来处理。

9. \`initialize()\`：初始化线程池。

10. \`Runtime.getRuntime().availableProcessors()\`：这个方法返回可用处理器的数目，也就是当前设备的 CPU 核心数。一般情况下，核心数越多，处理器的处理能力就越强，因此可以根据核心数来设置线程池中的核心线程数和最大线程数。

11. \`ThreadPoolTaskExecutor\`：这个类是 Spring Framework 提供的一个线程池实现类。通过创建这个类的实例，我们可以方便地设置线程池的各种配置，如核心线程数、最大线程数、工作队列容量、拒绝策略、线程名前缀等等。

12. \`Bean\` 注解：这个注解用于告诉 Spring Framework，这个方法返回的对象需要被注册为一个 bean，可以在其他地方通过依赖注入来使用。

综上所述，这段代码用于创建一个自定义的线程池，用于执行使用