Scheduled线程池配置

在使用 Spring 的 Scheduled 注解时，如果任务执行时间较长，或者任务数量较多，可能会影响系统的性能和稳定性。为了避免这种情况，可以通过配置 Scheduled 线程池来控制任务的并发执行。

在 Spring Boot 中，可以通过在 application.properties 或 application.yml 文件中添加以下配置来配置 Scheduled 线程池：

spring.task.scheduling.pool.size=10

这里配置了一个大小为 10 的线程池，用于执行 Scheduled 任务。如果任务数量超过了线程池大小，那么多余的任务就会等待线程池中的线程执行完毕后再执行。

除了设置线程池大小外，还可以通过其他配置项来控制 Scheduled 线程池的行为：

- spring.task.scheduling.thread-name-prefix: 线程名称前缀，默认为 "scheduling-"
- spring.task.scheduling.shutdown.await-termination: 是否等待任务结束后再关闭线程池，默认为 true
- spring.task.scheduling.shutdown.timeout: 关闭线程池的超时时间，默认为 10 秒

需要注意的是，在配置 Scheduled 线程池时，不能使用 FixedThreadPool 等固定大小的线程池，因为这样会导致任务无法并发执行。应该使用 CachedThreadPool 等支持动态扩容的线程池。

相关问题

springboot scheduled线程池

在Spring Boot中，我们可以使用`@Scheduled`注解来实现定时任务。默认情况下，`@Scheduled`注解会创建一个单线程的线程池来执行定时任务。但是，当我们需要执行大量的定时任务时，单线程的线程池可能会成为瓶颈，导致任务执行时间过长。

为了解决这个问题，我们可以通过配置一个任务执行器来使用线程池执行定时任务。具体步骤如下：

1. 在`@Configuration`类中定义一个`TaskScheduler` bean，并配置线程池。

@Configuration
@EnableScheduling
public class ScheduledConfig {

    @Bean
    public TaskScheduler taskScheduler() {
        ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
        scheduler.setPoolSize(10);
        scheduler.setThreadNamePrefix("scheduled-thread-");
        return scheduler;
    }
}

2. 在定时任务的方法上添加`@Scheduled`注解，并指定`fixedDelay`或`cron`表达式。

@Service
public class MyService {

    @Scheduled(fixedDelay = 5000)
    public void doSomething() {
        // 执行定时任务
    }
}

在上面的例子中，`fixedDelay`属性指定了任务的执行间隔为5秒。当我们启动应用程序时，Spring Boot将会自动创建一个线程池来执行所有的定时任务。

如果我们需要在应用程序关闭时关闭线程池，可以在`@Configuration`类中添加一个`@PreDestroy`方法来关闭线程池。

@Configuration
@EnableScheduling
public class ScheduledConfig {

    private final TaskScheduler taskScheduler;

    public ScheduledConfig(TaskScheduler taskScheduler) {
        this.taskScheduler = taskScheduler;
    }

    @PreDestroy
    public void destroy() {
        if (taskScheduler instanceof ThreadPoolTaskScheduler) {
            ((ThreadPoolTaskScheduler) taskScheduler).shutdown();
        }
    }

    @Bean
    public TaskScheduler taskScheduler() {
        ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
        scheduler.setPoolSize(10);
        scheduler.setThreadNamePrefix("scheduled-thread-");
        return scheduler;
    }
}

在上面的例子中，我们通过`@PreDestroy`方法来关闭线程池。当应用程序关闭时，Spring Boot将会自动调用这个方法来关闭线程池。

springboot scheduled线程池 demo

以下是一个使用 Spring Boot Scheduled 的线程池示例：

1. 首先，您需要在 Maven 或 Gradle 中添加以下依赖项：

<!-- Spring Boot Starter Web -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
    <version>2.4.5</version>
</dependency>

<!-- Spring Boot Starter Scheduled -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-quartz</artifactId>
    <version>2.4.5</version>
</dependency>

2. 创建一个 `ThreadPoolConfig` 类，用于设置线程池配置：

@Configuration
public class ThreadPoolConfig {

    @Bean
    public ExecutorService taskExecutor() {
        return Executors.newScheduledThreadPool(10);
    }
}

3. 创建一个 `ScheduledTask` 类，用于编写定时任务逻辑：

@Component
public class ScheduledTask {

    @Autowired
    private ExecutorService executorService;

    @Scheduled(fixedDelay = 1000)
    public void task() {
        executorService.submit(() -> {
            // 任务逻辑
        });
    }
}

4. 运行应用程序并查看日志，您将看到定时任务正在运行。

注意：在使用 Scheduled 注解时，需要确保该注解所在的类被 Spring 容器扫描到。如果您使用了 Spring Boot Starter Web，则可以通过在主类上添加 `@SpringBootApplication` 注解来实现自动扫描。