手动配置线程池 实现

要手动创建线程池来实现异步操作，可以使用Java中的ExecutorService接口和ThreadPoolExecutor类来完成。 首先，我们需要创建一个ThreadPoolExecutor对象。可以通过ThreadPoolExecutor的构造函数来指定线程池的大小、最大线程数、线程空闲时间等参数。例如： ```java int corePoolSize = 5; // 线程池核心线程数 int maxPoolSize = 10; // 线程池最大线程数 long keepAliveTime = 60; // 线程空闲时间（单位：秒） ExecutorService executorService = new ThreadPoolExecutor( corePoolSize, maxPoolSize, keepAliveTime, TimeUnit.SECONDS, new LinkedBlockingQueue<>() ); ``` 接下来，可以使用executorService的submit方法来提交一个任务给线程池执行。submit方法会返回一个Future对象，可以用来获取异步操作的结果。例如： ```java Future<String> futureResult = executorService.submit(() -> { // 异步任务逻辑代码 return "异步操作结果"; }); ``` 如果需要获取异步操作的结果，可以调用Future对象的get方法。get方法会阻塞当前线程，直到异步任务完成并返回结果。例如： ```java try { String result = futureResult.get(); System.out.println("异步操作结果：" + result); } catch (InterruptedException | ExecutionException e) { e.printStackTrace(); } ``` 最后，记得在程序结束时关闭线程池，释放资源： ```java executorService.shutdown(); ``` 这样就可以手动创建线程池来实现异步操作了。注意，线程池的大小和最大线程数需要根据实际需求进行配置，以充分利用系统资源并避免资源浪费。

### 配置线程池实现 Scheduled 定时任务 在 Spring Boot 项目中，为了更高效地管理和控制定时任务的执行，可以手动配置线程池。这不仅能够提升性能，还能更好地处理高并发场景下的任务调度。 #### 创建自定义线程池配置类 创建一个新的 Java 类 `ThreadPoolTaskSchedulerConfig` 来配置线程池： ```java import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.scheduling.annotation.EnableScheduling; import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler; @Configuration @EnableScheduling public class ThreadPoolTaskSchedulerConfig { @Bean(destroyMethod = "shutdown") public ThreadPoolTaskScheduler threadPoolTaskScheduler() { ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler(); taskScheduler.setPoolSize(10); // 设置核心线程数为10 taskScheduler.setThreadNamePrefix("Scheduled-"); // 设置线程名称前缀 return taskScheduler; } } ``` 此代码片段展示了如何通过 `ThreadPoolTaskScheduler` 构建一个具有固定大小的核心线程池，并指定线程名前缀以便于调试和日志记录[^1]。 #### 编写带有 @Scheduled 的服务类 接下来编写具体的服务逻辑，在其中应用 `@Scheduled` 注解来标记需要定期运行的方法： ```java import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Service; @Service public class MyScheduledService { private static final Logger logger = LoggerFactory.getLogger(MyScheduledService.class); @Scheduled(cron = "*/5 * * * * ?") // 每隔五秒执行一次 public void performTask() { logger.info("Executing scheduled task at {}", System.currentTimeMillis()); } } ``` 这里使用了 cron 表达式 `"*/5 * * * * ?"` 来表示每五分钟触发一次的任务；实际开发过程中可以根据业务需求调整时间间隔[^2]。 #### 启用自动装配功能 确保应用程序启动类上有 `@EnableScheduling` 注解以启用计划任务支持: ```java @SpringBootApplication @EnableScheduling public class Application { public static void main(String[] args) { SpringApplication.run(Application.class, args); } } ``` 这样就完成了基于自定义线程池的手动配置以及简单的定时任务实现了[^3]。