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线程池来执行任务。

在Spring Boot中，我们可以通过在@Configuration注解的类中定义一个ScheduledExecutorService类型的bean来实现Scheduled线程池的配置，如下所示：

@Configuration
public class ScheduledConfig {
 
    @Bean(destroyMethod="shutdown")
    public ScheduledExecutorService scheduledExecutorService() {
        return Executors.newScheduledThreadPool(5);
    }
}

上述代码中，我们定义了一个ScheduledExecutorService类型的bean，使用newScheduledThreadPool方法创建了一个大小为5的线程池，并通过destroyMethod指定了当应用关闭时销毁线程池。

接下来，我们可以在需要执行定时任务的方法上添加@Scheduled注解，并指定cron表达式，如下所示：

@Component
public class ScheduledTask {
 
    @Scheduled(cron = "0 0/1 * * * ?")
    public void task1() {
        // 任务1的业务逻辑
    }
 
    @Scheduled(cron = "0 0/2 * * * ?")
    public void task2() {
        // 任务2的业务逻辑
    }
}

上述代码中，我们在ScheduledTask类中定义了两个方法，分别用@Scheduled注解指定了cron表达式，这样就可以在应用启动后按照指定的时间间隔执行任务了。需要注意的是，我们不需要手动启动线程池，Spring Boot会自动将ScheduledExecutorService类型的bean注入到@Scheduled注解的方法中，并使用线程池来执行任务。

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` 注解来实现自动扫描。