spring定时任务Scheduled与定时任务线程池配置SchedulingConfigurer ，Java

Posted 2022-11-24 zhangphil

spring定时任务Scheduled与定时任务线程池配置SchedulingConfigurer ，Java

spring默认定时任务的使用

package zhangphil.demo;

import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

@Slf4j
@Component
@EnableScheduling
public class MyScheduledTask 
    private int a = 0;
    private int b = 0;

    @Scheduled(fixedRate = 1000 * 3, initialDelay = 1000 * 6)
    private void simpleScheduled1() 
        log.info("定时1-", a++);
    

    @Scheduled(fixedRate = 1000 * 3, initialDelay = 1000 * 6)
    private void simpleScheduled2() 
        log.info("定时2-", b++);
    

输出：

有说法认为需要把@EnableScheduling注解放在主应用Application上，其实不必，只需要把@EnableScheduling添加到使用定时任务的类上，然后在类的内部定时任务函数上添加注解@Scheduled即可。

定时任务的线程池配置

spring默认会创建一个只有1个线程任务的线程池启动定时任务，观察上面的输出也可以看到，这个线程的名称叫scheduling-1。试想假设项目中的线程任务很多时候，1个线程的线程池就不够了。可以通过配置线程池的SchedulingConfigurer参数，实现启动多个线程任务的线程池容纳定时任务：

package zhangphil.demo;

import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;

@Configuration
public class MySchedulingConfigurer implements SchedulingConfigurer 

    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) 
        //设定长度5的定时任务线程池
        ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(5);
        taskRegistrar.setScheduler(scheduledExecutorService);
    

输出：

 可以看出此时启动的定时任务归属到不同的子线程中。