转载

Spring Boot下配置定时任务及线程池和多线程池执行

配置基础的定时任务

最基本的配置方法，而且这样配置定时任务是单线程串行执行的，也就是说每次只能有一个定时任务可以执行，可以试着声明两个方法，在方法内写一个死循环，会发现一直卡在一个任务上不动，另一个也没有执行。

启动类

添加 @EnableScheduling 开启对定时任务的支持

@EnableScheduling
@SpringBootApplication
public class TestScheduledApplication extends SpringBootServletInitializer {

    @Override 
    protected SpringApplicationBuilder configure(SpringApplicationBuilder builder) {
        return builder.sources(this.getClass());
    }

    public static void main(String[] args) {
        new SpringApplicationBuilder(TestScheduledApplication.class).web(true).run(args);
    }
}

配置执行定时任务的类

添加 @Component 扫描本类，在方法上添加 @Scheduled 注解声明定时任务，配置时间周期

@Component
public class TestTask1 {
    private static final Logger logger = LogManager.getLogger();

    // 间隔1秒执行一次
    @Scheduled(cron = "0/1 * * * * ?")
    public void method1() {
        logger.info("——————————method1 start——————————");
        logger.info("——————————method1 end——————————");
    }
}

配置线程池执行定时任务

因为有时候需要执行的定时任务会很多，如果是串行执行会带来一些问题，比如一个很耗时的任务阻塞住了，一些需要短周期循环执行的任务也会卡住，所以可以配置一个线程池来并行执行定时任务

配置线程池

添加 @EnableAsync 开启对异步的支持

@Configuration
@EnableAsync
public class ExecutorConfig {
 
    @Bean
    public Executor executor1() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setThreadNamePrefix("test-schedule2-");
        executor.setMaxPoolSize(20);
        executor.setCorePoolSize(15);
        executor.setQueueCapacity(0);
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        return executor;
    }
}

配置定时任务异步执行

添加 @Async 注解，表示该定时任务是异步执行的，因为上面线程池配置了名字，所以可以看到打印的日志是该线程池中的线程在执行任务，如果没有配置线程池的话会默认使用 SimpleAsyncTaskExecutor ，这个异步执行器每次都会开启一个子线程执行，性能消耗比较大，所以最好是自己配置线程池
```
@Async
@Scheduled(cron = "0/1 * * * * ?")
public void method1() {
    logger.info("——————————method1 start——————————");
    logger.info("——————————method1 end——————————");
}
```

配置多个线程池分别执行不同的定时任务

因为有些定时任务是比较重要的，有些则是不太重要的，想把定时任务分别放到不同的线程池中，也是可以实现的。

配置多个线程池

分别配置两个线程池

@Configuration
@EnableAsync
public class ExecutorConfig1 {

    @Bean
    public Executor executor1() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setThreadNamePrefix("test-schedule1-");
        executor.setMaxPoolSize(20);
        executor.setCorePoolSize(15);
        executor.setQueueCapacity(0);
        executor.setRejectedExecutionHandler(new    ThreadPoolExecutor.CallerRunsPolicy());
        return executor;
    }

 
    @Bean
    public Executor executor2() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setThreadNamePrefix("test-schedule2-");
        executor.setMaxPoolSize(20);
        executor.setCorePoolSize(15);
        executor.setQueueCapacity(0);
        executor.setRejectedExecutionHandler(new    ThreadPoolExecutor.CallerRunsPolicy());
        return executor;
       }
}

定时任务显示指定调用线程池

因为上面在配置类里面初始化了两个线程池，所以会有两个线程池分别叫 executor1 和 executor1 被生成放到容器中，因为 @Bean 注解生成的对象默认就是和方法名相同的名字，而 @Async 注解是可以指定使用哪个线程池的。这样就可以在不同的线程池中执行不同的定时任务了

// 间隔1秒执行一次
@Async("executor1")
@Scheduled(cron = "0/1 * * * * ?")
public void method1() {
    logger.info("——————————method1 start——————————");
    logger.info("——————————method1 end——————————");
}

// 间隔1秒执行一次
@Scheduled(cron = "0/1 * * * * ?")
@Async("executor2")
public void method2() {
    logger.info("——————————method2 start——————————");
    logger.info("——————————method2 end——————————");
}

注意：

SimpleAsyncTaskExecutor
spring
@Async("executor2")

原文 https://segmentfault.com/a/1190000020299913

正文到此结束

所属分类：编程技术 Java

本文标签： App queue https 时间线程池 servlet IDE http web UI ask springboot spring 配置 core id cat build IO 线程 ThreadPoolExecutor executor tar final bean
版权声明： 本文为互联网转载文章，出处已在文章中说明(部分除外)。如果侵权，请联系本站长删除，谢谢。
本文海报： 生成海报一生成海报二

其他链接

关于本站

本站定位：个人技术类博客

本站作用：写博客、记日志、闲聊扯淡鼓捣技术。

问题交流

Spring Boot下配置定时任务及线程池和多线程池执行

配置基础的定时任务

配置线程池执行定时任务

配置多个线程池分别执行不同的定时任务

注意：

热门推荐

相关文章

说给你听

本文目录

随机标签

书籍教程

近期评论

网站信息

其他链接

关于本站

问题交流