java如何计时器
如何在Java中使用计时器
Java提供了多种方式实现计时器功能,常用的有java.util.Timer类、ScheduledExecutorService接口以及第三方库如Quartz。以下是具体实现方法:
使用java.util.Timer
Timer类可以安排一次性或重复执行的任务。
import java.util.Timer;
import java.util.TimerTask;
public class SimpleTimer {
public static void main(String[] args) {
Timer timer = new Timer();
TimerTask task = new TimerTask() {
@Override
public void run() {
System.out.println("Task executed at: " + System.currentTimeMillis());
}
};
// 延迟1秒后执行,之后每2秒重复执行
timer.schedule(task, 1000, 2000);
}
}
使用ScheduledExecutorService
ScheduledExecutorService是更现代的替代方案,支持线程池管理。
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.newScheduledThreadPool(1);
Runnable task = () -> System.out.println("Task executed at: " + System.currentTimeMillis());
// 延迟1秒后执行,之后每2秒重复执行
executor.scheduleAtFixedRate(task, 1, 2, TimeUnit.SECONDS);
}
}
使用Spring框架的@Scheduled
如果项目基于Spring Boot,可以使用注解简化定时任务配置。
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
@Component
public class SpringScheduler {
@Scheduled(fixedRate = 2000)
public void scheduledTask() {
System.out.println("Task executed at: " + System.currentTimeMillis());
}
}
需在启动类添加@EnableScheduling注解启用定时任务功能。
使用Quartz框架
对于复杂调度需求(如CRON表达式),Quartz是更强大的选择。
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;
public class QuartzExample {
public static void main(String[] args) throws SchedulerException {
JobDetail job = JobBuilder.newJob(MyJob.class)
.withIdentity("myJob", "group1").build();
Trigger trigger = TriggerBuilder.newTrigger()
.withIdentity("myTrigger", "group1")
.startNow()
.withSchedule(SimpleScheduleBuilder.simpleSchedule()
.withIntervalInSeconds(2)
.repeatForever())
.build();
Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
scheduler.scheduleJob(job, trigger);
scheduler.start();
}
public static class MyJob implements Job {
@Override
public void execute(JobExecutionContext context) {
System.out.println("Quartz job executed at: " + System.currentTimeMillis());
}
}
}
注意事项
Timer是单线程的,一个任务延迟会影响其他任务。ScheduledExecutorService推荐用于大多数场景,支持多线程和更好的异常处理。- 长时间运行的任务应考虑使用线程池管理资源。
- 分布式环境可能需要分布式调度框架如Elastic-Job或XXL-JOB。







