springboot使用定時器@Scheduled不管用的解決

Posted on by

使用定時器@Scheduled不管用

如果是一開始就不能用就是沒寫@EnableScheduling註解，如果是用著用著不管用瞭 是因為@Scheduled是單線程，有定時器在工作或者沒有運行完畢，所以造成瞭線程堵塞所以導致下一個定時器不能運行增加一個方法類

package com.llt;
import org.springframework.boot.autoconfigure.batch.BatchProperties;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;
import java.lang.reflect.Method;
import java.util.concurrent.Executors;
@Configuration
public class ScheduleConfig implements SchedulingConfigurer {
    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        Method[] methods = BatchProperties.Job.class.getMethods();
        int defaultPoolSize = 3;
        int corePoolSize = 0;
        if (methods != null && methods.length > 0) {
            for (Method method : methods) {
                Scheduled annotation = method.getAnnotation(Scheduled.class);
                if (annotation != null) {
                    corePoolSize++;
                }
            }
            if (defaultPoolSize > corePoolSize)
                corePoolSize = defaultPoolSize;
        }
        taskRegistrar.setScheduler(Executors.newScheduledThreadPool(corePoolSize));
    }
}

就好瞭！

多個@Scheduled定時器不執行

最近項目中經常有用到@Scheduled註解，在內測時由於數據量小(沒有進行壓力測)所以每個線程執行都很快，但線上後發現部分功能無法使用，最後定位是部分的定時器沒有執行，後查閱資料和Springboot源碼後

ScheduledTaskRegistrar在啟動時，如果沒有指定線程池的大小，默認會創建核心線程數為1的默認線程池，故而當項目中出現多個@Scheduled線程時，隻能一個個的執行，從而導致個別線程執行時間過長(或長期執行)時，其他定時器不能按照指定的規則進行執行。

解決方法

1.在項目初始化時指定其執行線程池的大小

import org.springframework.boot.autoconfigure.batch.BatchProperties;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;
 
import java.lang.reflect.Method;
import java.util.Arrays;
import java.util.Objects;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.atomic.AtomicInteger;
 
/**
 * 程序名 : ScheduledTaskConfiguration
 * 建立日期: 2021-02-23 9:33
 * 模塊 : Scheduled任務線程池設置
 * 描述 : 讀取項目中使用瞭@Scheduled註解的方法，默認所有方法在項目創建時都需要按照設定的規則執行
 * 備註 : //TODO
 * <p>
 * 修改歷史
 * 序號 	       日期 		        修改人 		         修改原因
 */
@Configuration
public class ScheduledTaskConfiguration implements SchedulingConfigurer {
    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        Method[] methods = BatchProperties.Job.class.getMethods();
        final AtomicInteger corePoolSize = new AtomicInteger();
        if (Objects.nonNull(methods) && methods.length > 0) {
            Arrays.stream(methods).forEach(method -> {
                final Scheduled annotation = method.getAnnotation(Scheduled.class);
                if (Objects.nonNull(annotation)) {
                    corePoolSize.incrementAndGet();
                }
            });
        }
        ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(corePoolSize.get());
        taskRegistrar.setScheduler(executor);
    }
}

2.將定時器設置為異步線程

/**
異步線程
定時器延遲1秒啟動，每距上一次執行完成後間隔3秒執行一次
*/
@Async("taskExecutor")
@Scheduled(initialDelay = 1000L, fixedDelay = 3000L)
public void test(){
   System.out.println("---"+System.currentTimeMillis());
 //業務內容
}

以上為個人經驗，希望能給大傢一個參考，也希望大傢多多支持WalkonNet。

推薦閱讀：