【线程池】SpringBoot 中使用线程池的示例

Spring Boot 中使用线程池的示例

在 Spring Boot 应用中，线程池常用于处理异步任务、提高并发性能或执行耗时操作而不阻塞主线程。下面是一个完整的示例：
1. 配置线程池

首先，在配置类中定义线程池：

1. import org.springframework.context.annotation.Bean;
2. import org.springframework.context.annotation.Configuration;
3. import org.springframework.scheduling.annotation.EnableAsync;
4. import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
6. import java.util.concurrent.Executor;
8. @Configuration
9. @EnableAsync
10. public class AsyncConfig {
11.    
12.     @Bean(name = "taskExecutor")
13.     public Executor taskExecutor() {
14.         ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
15.         executor.setCorePoolSize(5);    // 核心线程数
16.         executor.setMaxPoolSize(10);     // 最大线程数
17.         executor.setQueueCapacity(100);  // 队列容量
18.         executor.setThreadNamePrefix("Async-Thread-"); // 线程名前缀
19.         executor.initialize();
20.         return executor;
21.     }
22. }

复制代码

2. 创建异步服务

创建一个使用线程池的服务：

1. import org.springframework.scheduling.annotation.Async;
2. import org.springframework.stereotype.Service;
4. @Service
5. public class EmailService {
7.     // 使用指定线程池执行
8.     @Async("taskExecutor")
9.     public void sendEmail(String to, String content) {
10.         // 模拟耗时操作
11.         try {
12.             System.out.println(Thread.currentThread().getName() + " 开始发送邮件给: " + to);
13.             Thread.sleep(2000); // 模拟发送邮件耗时
14.             System.out.println("邮件发送成功: " + content);
15.         } catch (InterruptedException e) {
16.             Thread.currentThread().interrupt();
17.             System.out.println("邮件发送被中断");
18.         }
19.     }
20. }

复制代码

3. 控制器调用

创建一个控制器来触发异步任务：

1. import org.springframework.beans.factory.annotation.Autowired;
2. import org.springframework.web.bind.annotation.GetMapping;
3. import org.springframework.web.bind.annotation.RestController;
5. @RestController
6. public class EmailController {
8.     @Autowired
9.     private EmailService emailService;
11.     @GetMapping("/send")
12.     public String sendEmails() {
13.         for (int i = 0; i < 10; i++) {
14.             emailService.sendEmail("user" + i + "@example.com", "测试邮件内容 " + i);
15.         }
16.         return "邮件发送请求已提交";
17.     }
18. }

复制代码

4. 实际应用场景

这个例子展示了线程池在以下场景中的应用：

• 批量发送邮件/短信：避免阻塞主线程，提高响应速度
  
• 日志记录：异步记录日志不影响主业务流程
  
• 数据导出：耗时的Excel导出操作
  
• 第三方API调用：异步调用外部服务
  
• 定时任务：使用 @Scheduled 注解配合线程池执行定时任务
  

5. 其他线程池使用方式

除了 @Async 注解，还可以直接使用线程池：

1. import org.springframework.beans.factory.annotation.Autowired;
2. import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
3. import org.springframework.stereotype.Service;
5. @Service
6. public class ReportService {
7.    
8.     @Autowired
9.     private ThreadPoolTaskExecutor taskExecutor;
10.    
11.     public void generateReports() {
12.         for (int i = 0; i < 20; i++) {
13.             final int reportId = i;
14.             taskExecutor.execute(() -> {
15.                 System.out.println(Thread.currentThread().getName() + " 生成报表: " + reportId);
16.                 // 模拟报表生成
17.                 try {
18.                     Thread.sleep(1000);
19.                 } catch (InterruptedException e) {
20.                     Thread.currentThread().interrupt();
21.                 }
22.             });
23.         }
24.     }
25. }

复制代码

这个示例展示了如何在 Spring Boot 应用中配置和使用线程池来处理异步任务，提高应用性能。

来源：程序园用户自行投稿发布，如果侵权，请联系站长删除
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！