1.如何实现定时任务- Java Timer/TimerTask 源码解析
2.java定时任务的定时表达式,每天早晨6:是每个月的1号和15号执行任务
3.java怎么每隔一秒钟输出一个随机数(1-10之间)
如何实现定时任务- Java Timer/TimerTask 源码解析
日常实现各种服务端系统时,我们一定会有一些定时任务的需求。比如会议提前半小时自动提醒,异步任务定时/周期执行等。那么如何去实现这样的phpwms源码一个定时任务系统呢? Java JDK提供的Timer类就是一个很好的工具,通过简单的API调用,我们就可以实现定时任务。
现在就来看一下java.util.Timer是如何实现这样的定时功能的。
首先,我们来看一下一个使用demo
基本的使用方法:
加入任务的API如下:
可以看到API方法内部都是调用sched方法,其中time参数下一次任务执行时间点,是通过计算得到。period参数为0的话则表示为一次性任务。
那么我们来看一下Timer内部是如何实现调度的。
内部结构
先看一下Timer的组成部分:
Timer有3个重要的模块,分别是wal机制hbase 源码 TimerTask, TaskQueue, TimerThread
那么,在加入任务之后,整个Timer是怎么样运行的呢?可以看下面的示意图:
图中所示是简化的逻辑,多个任务加入到TaskQueue中,会自动排序,队首任务一定是当前执行时间最早的任务。TimerThread会有一个一直执行的循环,从TaskQueue取队首任务,判断当前时间是芜湖离淮南源码否已经到了任务执行时间点,如果是则执行任务。
工作线程
流程中加了一些锁,用来避免同时加入TimerTask的并发问题。可以看到sched方法的逻辑比较简单,task赋值之后入队,队列会自动按照nextExecutionTime排序(升序,排序的实现原理后面会提到)。
从mainLoop的黑河网站源码源码中可以看出,基本的流程如下所示
当发现是周期任务时,会计算下一次任务执行的时间,这个时候有两种计算方式,即前面API中的
优先队列
当从队列中移除任务,或者是修改任务执行时间之后,队列会自动排序。始终保持执行时间最早的任务在队首。 那么这是云闪闪回收源码如何实现的呢?
看一下TaskQueue的源码就清楚了
可以看到其实TaskQueue内部就是基于数组实现了一个最小堆 (balanced binary heap), 堆中元素根据 执行时间nextExecutionTime排序,执行时间最早的任务始终会排在堆顶。这样工作线程每次检查的任务就是当前最早需要执行的任务。堆的初始大小为,有简单的倍增扩容机制。
TimerTask 任务有四种状态:
Timer 还提供了cancel和purge方法
常见应用
Java的Timer广泛被用于实现异步任务系统,在一些开源项目中也很常见, 例如消息队列RocketMQ的 延时消息/消费重试 中的异步逻辑。
上面这段代码是RocketMQ的延时消息投递任务 ScheduleMessageService 的核心逻辑,就是使用了Timer实现的异步定时任务。
不管是实现简单的异步逻辑,还是构建复杂的任务系统,Java的Timer确实是一个方便实用,而且又稳定的工具类。从Timer的实现原理,我们也可以窥见定时系统的一个基础实现:线程循环 + 优先队列。这对于我们自己去设计相关的系统,也会有一定的启发。
java定时任务的定时表达式,每天早晨6:是每个月的1号和号执行任务
Java定时任务的定时表达式实现中,我们可以看到一个例子,展示了如何在每天早晨6点,以及每个月的1号和号执行特定的任务。下面的代码片段展示了如何使用`java.util.Timer`和`TimerTask`类来实现这个需求:
java
public class MyTimer {
public static void main(String[] args) {
Timer timer1 = new Timer();
// 每天早上6:执行Task1
timer1.schedule(new Task1(), getTargetDate(0, 6, , 0), * * * );
// 每月1号执行Task2(类型1)
timer1.schedule(new Task2(1), getTargetDate(1, 6, , 0));
// 每月号执行Task2(类型2)
timer1.schedule(new Task2(2), getTargetDate(, 6, , 0));
}
// ...省略其他方法...
public static Date getTargetDate(int day, int hour, int minute, int second) {
// ...省略日期计算逻辑...
}
// ...省略Task1和Task2类的内容...
}
这段代码的核心是通过`schedule`方法,设置`TimerTask`在特定的时间执行。`getTargetDate`方法用于计算下次执行任务的具体日期,根据不同日期条件进行调整。通过`Task2`的类型参数,我们可以区分每月1号和号的任务。当任务执行完毕后,会取消当前任务并重新安排在下一次指定日期。
java怎么每隔一秒钟输出一个随机数(1-之间)
可以用 java.util.Timer(计时器) 以及 java.util.TimerTask(计时任务) 来实现,具体代码如下:import java.io.IOException;import java.util.Random;
import java.util.Timer;
import java.util.TimerTask;
public class Main {
public static void main(String[] args) throws IOException, InterruptedException {
// 创建一个计时器
Timer timer = new Timer();
// 开启一个计时调度,延迟 0毫秒(也就是立即开始执行),调度评率: 1秒
timer.schedule(new TimerTask() {
@Override
public void run() {
// 生成随机数逻辑
Random r = new Random();
int num = r.nextInt() + 1;
System.out.println("随机数为:" + num);
}
}, 0L, L);
// timer.cancel(); // 关闭计时器
}
}