spring boot默认单线程排队跑定时任务问题记录

小小明童鞋

发布于 2019-12-15 20:33:54

1.8K0

发布于 2019-12-15 20:33:54

文章被收录于专栏：java系列博客 java系列博客java系列博客

作者：小小明童鞋

链接：https://cloud.tencent.com/developer/article/1554026

问题描述：在使用springboot默认的定时任务时，若存在多个任务，框架默认只启动一个线程执行，会导致有些任务不能在指定时间开始执行

另，关于分布式下定时任务同步锁问题，会再单独写一篇记录

测试默认情况下定时任务的线程名称：

package com.example.demo.job;

import net.javacrumbs.shedlock.core.SchedulerLock;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.time.LocalDateTime;

@Component
@EnableScheduling
public class TestJob {


    @Scheduled(cron = "0/5 * * * * ?")
    @SchedulerLock(name = "test1-task", lockAtMostForString = "PT28M", lockAtLeastForString = "PT28M")
    public void execute1() {
        String curName = Thread.currentThread().getName();
        System.out.println("当前时间:" + LocalDateTime.now() + "  任务execute1对应的线程名: " + curName);
        try {
            Thread.sleep(1000);
        } catch (Exception e) {
            e.printStackTrace();
        }

    }

    @Scheduled(cron = "0/5 * * * * ?")
    @SchedulerLock(name = "test2-task", lockAtMostForString = "PT28M", lockAtLeastForString = "PT28M")
    public void execute2() {

        String curName = Thread.currentThread().getName();
        System.out.println("当前时间:" + LocalDateTime.now() + "  任务execute2对应的线程名: " + curName);
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    @Scheduled(cron = "0/10 * * * * ?")
    @SchedulerLock(name = "test3-task", lockAtMostForString = "PT28M", lockAtLeastForString = "PT28M")
    public void execute3() {

        String curName = Thread.currentThread().getName();
        System.out.println("当前时间:" + LocalDateTime.now() + "  任务execute3对应的线程名: " + curName);
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

}

结果如下：

spring boot 自带的定时任务默认只起一个线程：

这种情况下，对于有些定时任务若设定在某一固定时刻开始执行，就可能出现需要排队而不能准时执行的情况。然后找了下解决方案，我不太想巴拉源码了，网上大家都扒出来了，就是为空初始化一个线程那段，直接点上解决方案：

在启动类里面加上如下代码：

/**
	 *  解决定时任务单线程排队问题，建立线程池
	 * @return
	 */
	@Bean
	public TaskScheduler taskScheduler() {
		ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
		taskScheduler.initialize();
		taskScheduler.setPoolSize(50);
		return taskScheduler;
	}

然后重新启动看下线程的情况：