多线程与任务调度是java开发中必须掌握的技能,在springBoot的开发中,多线程和任务调度变得越来越简单。实现方式可以通过实现ApplicationRunner接口,重新run的方法实现多线程。任务调度则可以使用@Scheduled注解
@Slf4j
@Service
@Transactional(rollbackFor = Exception.class)
public class ToolServiceThread implements ApplicationRunner {
@Autowired
private TmpMUserService tmpMUserService;
@Override
public void run(ApplicationArguments args) throws Exception {
log.info("开启线程.....,");
// 处理用户手机号
// tmpMUserService.updateOne();
}
/**
* 定时任务 早上0点10分
*/
// @Scheduled(cron = "0 10 0 * * ?")
@Scheduled(cron = "0 0/10 * * * ?") // 每10分钟刷新
public void hotelTask() throws Exception {
}
}
使用java.util.Timer类
import java.util.Timer;
import java.util.TimerTask;
public class TimerExample {
public static void main(String[] args) {
Timer timer = new Timer();
TimerTask task = new TimerTask() {
@Override
public void run() {
System.out.println("执行定时任务!");
}
};
// 延迟5秒后开始执行任务,然后每隔2秒执行一次
timer.schedule(task, 5000, 2000);
}
}
2.使用ScheduledExecutorService
ScheduledExecutorService
?是Java 5及以上版本中提供的一个更加强大和灵活的定时任务执行器。
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
public class ScheduledExecutorExample {
public static void main(String[] args) {
ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor();
executor.scheduleAtFixedRate(() -> {
System.out.println("执行定时任务!");
}, 5, 2, TimeUnit.SECONDS); // 延迟5秒后开始执行,然后每隔2秒执行一次
}
}
3.使用Spring的@Scheduled注解?(适用于Spring Boot应用)
如果你正在使用Spring Boot,你可以使用@Scheduled
注解来轻松地实现定时任务。首先,确保你的Spring Boot应用已经启用了定时任务支持:在主类上添加@EnableScheduling
注解。然后,你可以在方法上添加@Scheduled
注解来指定任务的执行计划。
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
@Component
@EnableScheduling
public class ScheduledTasks {
@Scheduled(fixedRate = 5000) // 每隔5秒执行一次
public void doSomething() {
System.out.println("执行定时任务!");
}
}