@Component
@Lazy(false)
public class UpdateDeviceTask {
private Logger logger = Logger.getLogger(UpdateDeviceTask.class.getName());
// 每5S执行
@Scheduled(cron = "0/5 * * * * ? ") //每10秒执行一次
@Async
public void TaskJob() throws InterruptedException {
logger.info(new Date().toLocaleString());
Thread.sleep(10000);
}
}
@Configuration
public class SchedulingConfigurerConfiguration implements SchedulingConfigurer {
@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
taskScheduler.setPoolSize(100);
taskScheduler.initialize();
taskRegistrar.setTaskScheduler(taskScheduler);
}
}