SpringBoot中的Scheduled单线程执行问题怎么解决

本篇内容主要讲解“SpringBoot中的Scheduled单线程执行问题怎么解决”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“springBoot中的Scheduled单线程执行问题怎么解决”吧!

问题描述

在一次SpringBoot中使用Scheduled定时任务时，发现某一个任务出现执行占用大量资源，会导致其他任务也执行失败。
类似于以下模拟场景，test1定时任务模拟有五秒钟执行时间，这时会同步影响到test2任务的执行，导致test2任务也变成五秒执行一次。

    @Scheduled(fixedRate = 1000)    public void test1() throws InterruptedException {        log.info(Thread.currentThread().getName() + " | task01 ");        Thread.sleep(5000);    }    @Scheduled(fixedRate = 2000)    public void test2() {        log.info(Thread.currentThread().getName() + " | task02 ");    }

原因分析：

经过相关资料查阅，发现Scheduled定时任务默认的线程数只有一个，进行定时任务调度时会同步的去调度，一个执行完成后再执行另一个，这是导致该问题的直接原因。

解决方案：

    @Bean    public TaskScheduler taskScheduler() {        ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();        // 设置线程数量        taskScheduler.setPoolSize(50);        return taskScheduler;    }

添加一个配置，设置TaskScheduler线程数为多个，这样再执行时就会异步执行了，各个定时任务间互不影响。

补充：

使用以下Java的util包中带的TimerTask也可以进行定时任务的执行。
以下参数中TimerTask是执行的任务，0表示第一次延迟0秒执行，3000表示每3000毫秒执行一次。

// true表示定时任务创建为守护线程                        Timer timer = new Timer(true);                        //timer.scheduleAtFixedRate();                        timer.schedule(new TimerTask() {                            @Override                            public void run() {                                logger.info(Thread.currentThread().getName() + "************"+ftpGaFilePrefix);                            }                        }, 0, 3000);

到此，相信大家对“SpringBoot中的Scheduled单线程执行问题怎么解决”有了更深的了解，不妨来实际操作一番吧！这里是编程网网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！