使用定时器@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;
@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.将定时器设置为异步线程
@Async("taskExecutor")
@Scheduled(initialDelay = 1000L, fixedDelay = 3000L)
public void test(){
System.out.println("---"+System.currentTimeMillis());
//业务内容
}以上为个人经验，希望能给大家一个参考，也希望大家多多支持编程网。
